• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java FailedToSendMessageException类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中kafka.common.FailedToSendMessageException的典型用法代码示例。如果您正苦于以下问题:Java FailedToSendMessageException类的具体用法?Java FailedToSendMessageException怎么用?Java FailedToSendMessageException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



FailedToSendMessageException类属于kafka.common包,在下文中一共展示了FailedToSendMessageException类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: sendMessages

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
/**
 * Send a set of messages. Each must have a "key" string value.
 * 
 * @param topic
 * @param msg
 * @throws FailedToSendMessageException
 * @throws JSONException
 */
@Override
public void sendMessages(String topic, List<? extends message> msgs)
		throws IOException, FailedToSendMessageException {
	log.info("sending " + msgs.size() + " events to [" + topic + "]");

	final List<KeyedMessage<String, String>> kms = new ArrayList<KeyedMessage<String, String>>(msgs.size());
	for (message o : msgs) {
		final KeyedMessage<String, String> data = new KeyedMessage<String, String>(topic, o.getKey(), o.toString());
		kms.add(data);
	}
	try {
		fProducer.send(kms);

	} catch (FailedToSendMessageException excp) {
		log.error("Failed to send message(s) to topic [" + topic + "].", excp);
		throw new FailedToSendMessageException(excp.getMessage(), excp);
	}
}
 
开发者ID:att,项目名称:dmaap-framework,代码行数:27,代码来源:KafkaPublisher.java


示例2: output

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
protected void
output(Collection<TaskData.ExecutionPlan.Node.Port> outputPorts,
       TaskData.ExecutionPlan executionPlan,
       Serializable result,
       UUID taskID) throws Exception {
    new RobustExecutor<Void, Void>(
            () -> {
                if (verbose) {
                    KafkaHelper.sendWithLog(taskID.toString(),
                            new TaskData(outputPorts, executionPlan, result),
                            producerSingleton.getInst(),
                            loggerSingleton.getInst());
                } else {
                    KafkaHelper.send(taskID.toString(),
                            new TaskData(outputPorts, executionPlan, result),
                            producerSingleton.getInst());
                }
            },
            Arrays.asList(
                    MessageSizeTooLargeException.class,
                    KafkaException.class,
                    FailedToSendMessageException.class)
    ).execute();
}
 
开发者ID:kyu-sz,项目名称:LaS-VPE-Platform,代码行数:25,代码来源:Stream.java


示例3: sendBatchMessage

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
/**
 * method publishing batch messages
 * 
 * @param topic
 * @param kms
 * throws IOException
 */
public void sendBatchMessage(String topic, ArrayList<KeyedMessage<String, String>> kms) throws IOException {
	try {
		fProducer.send(kms);

	} catch (FailedToSendMessageException excp) { 
		log.error("Failed to send message(s) to topic [" + topic + "].", excp);
		throw new FailedToSendMessageException(excp.getMessage(), excp);
	}

}
 
开发者ID:att,项目名称:dmaap-framework,代码行数:18,代码来源:KafkaPublisher.java


示例4: handle

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
@Override
public void handle(Seq<KeyedMessage<String, String>> messages) {
    try {
        super.handle(messages);
    } catch (FailedToSendMessageException e) {
        KruxStdLib.STATSD.count("dropped_messages", messages.size());
    }

}
 
开发者ID:krux,项目名称:tcp-stream-kafka-producer,代码行数:10,代码来源:KruxProducerEventHandler.java


示例5: sendOrReportFailure

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
private boolean sendOrReportFailure(String topic, final byte[] msg) {
    final boolean nonNullTopic = !("null".equals(topic));
    if (nonNullTopic) {
        try {
            producer.send(new KeyedMessage<byte[], byte[]>(topic, msg));
        } catch (FailedToSendMessageException e) {
            log.warn("Failed to send to topic {}", topic, e);
            failedToSendMessageExceptions.incrementAndGet();
        }
    }
    return nonNullTopic;
}
 
开发者ID:airbnb,项目名称:plog,代码行数:13,代码来源:KafkaHandler.java


示例6: sendMessageToKafka

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
/**
 * Sends messages to Kafka topic using specified properties in kafka.properties file.
 *
 * @param producer kafka producer provided by the caller
 * @param event    event that should be sent to Kafka Broker
 */
protected void sendMessageToKafka(Producer producer, Message<JsonObject> event) {

    if (!isValid(event.body().getString(PAYLOAD))) {
        logger.error("Invalid kafka message provided. Message not sent to kafka...");
        sendError(event, String.format("Invalid kafka message provided. Property [%s] is not set.", PAYLOAD)) ;
        return;
    }

    try {
        final MessageHandler messageHandler = messageHandlerFactory.createMessageHandler(serializerType);

        String topic = isValid(event.body().getString(TOPIC)) ? event.body().getString(TOPIC) : getTopic();     
        String partKey = event.body().getString(PART_KEY);

        long startTime = System.currentTimeMillis();
        
        messageHandler.send(producer, topic, partKey, event.body());
        
        statsDClient.recordExecutionTime("submitted", (System.currentTimeMillis()-startTime));
        
        
        sendOK(event);
        logger.info(String.format("Message sent to kafka topic: %s. Payload: %s", topic, event.body().getString(PAYLOAD)));
    } catch (FailedToSendMessageException ex) {
        sendError(event, "Failed to send message to Kafka broker...", ex);
    }
}
 
开发者ID:awin,项目名称:mod-kafka,代码行数:34,代码来源:KafkaMessageProcessor.java


示例7: sendMessageStatsDDisabled

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
@Test(expected = FailedToSendMessageException.class)
public void sendMessageStatsDDisabled() throws Exception {
    JsonObject jsonObject = new JsonObject();
    jsonObject.putString(EventProperties.PAYLOAD, MESSAGE);

    Handler<Message<JsonObject>> replyHandler = new Handler<Message<JsonObject>>() {
        public void handle(Message<JsonObject> message) {
            assertEquals("error", message.body().getString("status"));
            assertTrue(message.body().getString("message").equals("Failed to send message to Kafka broker..."));
            testComplete();
        }
    };
    vertx.eventBus().send(ADDRESS, jsonObject, replyHandler);
}
 
开发者ID:awin,项目名称:mod-kafka,代码行数:15,代码来源:KafkaModuleDeployWithStatsdEnabledConfigIT.java


示例8: sendMessage

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
@Test(expected = FailedToSendMessageException.class)
public void sendMessage() throws Exception {
    JsonObject jsonObject = new JsonObject();
    jsonObject.putBinary(EventProperties.PAYLOAD, MESSAGE.getBytes());

    Handler<Message<JsonObject>> replyHandler = new Handler<Message<JsonObject>>() {
        public void handle(Message<JsonObject> message) {
            assertEquals("error", message.body().getString("status"));
            assertTrue(message.body().getString("message").equals("Failed to send message to Kafka broker..."));
            testComplete();
        }
    };
    vertx.eventBus().send(ADDRESS, jsonObject, replyHandler);
}
 
开发者ID:awin,项目名称:mod-kafka,代码行数:15,代码来源:ByteArraySerializerIT.java


示例9: sendMessage

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
@Test(expected = FailedToSendMessageException.class)
public void sendMessage() throws Exception {
    JsonObject jsonObject = new JsonObject();
    jsonObject.putString(EventProperties.PAYLOAD, MESSAGE);

    Handler<Message<JsonObject>> replyHandler = new Handler<Message<JsonObject>>() {
        public void handle(Message<JsonObject> message) {
            assertEquals("error", message.body().getString("status"));
            assertTrue(message.body().getString("message").equals("Failed to send message to Kafka broker..."));
            testComplete();
        }
    };
    vertx.eventBus().send(ADDRESS, jsonObject, replyHandler);
}
 
开发者ID:awin,项目名称:mod-kafka,代码行数:15,代码来源:KafkaModuleDeployWithCorrectConfigIT.java


示例10: sendMessage

import kafka.common.FailedToSendMessageException; //导入依赖的package包/类
/**
 * Send a message with a given topic and key.
 * 
 * @param msg
 * @throws FailedToSendMessageException
 * @throws JSONException
 */
@Override
public void sendMessage(String topic, message msg) throws IOException, FailedToSendMessageException {
	final List<message> msgs = new LinkedList<message>();
	msgs.add(msg);
	sendMessages(topic, msgs);
}
 
开发者ID:att,项目名称:dmaap-framework,代码行数:14,代码来源:KafkaPublisher.java



注:本文中的kafka.common.FailedToSendMessageException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java PutMappingAction类代码示例发布时间:2022-05-22
下一篇:
Java StringShaderSource类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap