从KafkaTemplate获取主题元数据

文章/答案/技术大牛

发布

1回答

spring-kafka

我已经从KafkaTemplate实现中看到，它不能访问实际的Kafka生产者。在KafkaTemplate中，我们可以使用这些相同的方法来包装实际的Kafka生产者方法。这可能会在更新的版本中实现吗？我可以实现它并发出拉取请求吗？

浏览 0提问于2016-09-07得票数 2

回答已采纳

1回答

当主题不可用/ kafka broker关闭时，无法通过KafkaTemplate抛出异常

spring-kafka

我正在通过Kafka模板向Kafka发送消息，但我想测试异常，所以我提供了错误的主题名称，但当我运行代码时，它说“获取相关id为2的元数据时出错：{ocf-oots-gr-outbound_123=LEADER_NOT_AVAILABLE”不可用，但主题本身是在Kafka中创建的，我也可以通过Kafka工具看到，当broker停止时，它也没有抛出异常。代码： KafkaTemplate<String, Object> kafkaTemplate = (<em

浏览 19提问于2019-07-22得票数 0

回答已采纳

5回答

Spring Kafka异步发送调用块

spring、asynchronous、apache-kafka、send、producer

代码是这样的：future.addCallback看看kafka客户端库，代码变得更加复杂，我没有花时间去理解它，但我猜它可能正在进行远程调用(至少是元数据？)在同一条线上。

浏览 20提问于2017-07-13得票数 19

回答已采纳

1回答

从Kafka主题中获取条目？

java、json、apache-kafka

我已经实现了两个数据库服务，他们必须通过Kafka集群进行通信。我已经用KafkaTemplate设置了第一个从POST方法发送条目的topic。我在终端中看到条目正在进入该主题。我如何从Kafka主题中获取它们并生成回POJO或DB条目？

浏览 22提问于2021-03-18得票数 0

1回答

春季批量向Kafka写入数据

spring、spring-boot、apache-kafka、spring-batch、spring-kafka

新的Kafka，最近我试图从春季批量获取数据，然后写入Kafka，但我不知道如何做到这一点。有人能帮我弄清楚如何将数据写入Kafka吗？下面是我用SpringBatch编写的获取数据的演示代码： @Configuration公共类FileReader { @Autowired private JobBuilderFactory jobBuilderFactory

浏览 47提问于2019-09-25得票数 0

1回答

Producer如何决定将消息放入哪个分区？

apache-kafka、apache-zookeeper

根据我的理解，主题被进一步划分为分区生产者发送消息。public class KafkaSender { private KafkaTemplate<String, String> kafkaTemplate; }根据这

浏览 0提问于2019-12-18得票数 1

1回答

如何修复回调发送记录时spring-kafka中“xxx ms后更新元数据失败”问题

java、apache-kafka、kafka-producer-api、spring-kafka

spring-kafka无法在回调中发送记录 ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send(} public void onSuccess(SendResult<String, String> result) { kafkaTemplate.send("anotherTopic", "key", &q

浏览 27提问于2019-02-02得票数 0

回答已采纳

1回答

如何使用带有Spring-kafka kafkaTemplate的sendDefault方法的DefaultPartitioner

spring-kafka

我正在尝试将消息发送到一个具有4个partitions.And的主题，我希望消息到达由DefaultPartitioner决定的分区(它使用键的散列) kafkaTemplate.sendDefault(DefaultPartitioner(job.getId()),job.getId(),job);我不确定如何让kafkaTemplate使用DefaultPartitioner来获取分区号。

浏览 1提问于2017-04-13得票数 1

1回答

spring集成kafka出站适配器生产者通道更新元数据

spring-integration、spring-kafka

<int-kafka:outbound-channel-adapter sync="false" </int-kafka:outbound-channel-adapter> <bean id="kafkaTemplate<

浏览 1提问于2020-04-26得票数 0

1回答

Kafka Consumer with JSON？

java、spring

可以使用Kafka从post HTTP请求中获取JSON对象，将它们放入主题中，然后将它们发送给消费者(数据库)吗？顺便说一句，下面是我的KafkaConfig类： @EnableKafkapublic class KafkaConfig { public KafkaTemplate<String, User> kafkaTemplate(){ return new KafkaTemplat

浏览 5提问于2021-03-17得票数 0

回答已采纳

1回答

Apache KafkaMetric取值方法已弃用，如何使用metricValue取而代之？

java、apache-kafka、spring-kafka

所以我创建了一个从Kafka主题获取指标的函数 for (final Object set : kafkaTemplate.metrics().entrySet()) {

浏览 0提问于2018-07-06得票数 1

1回答

在Spring上选择分区创建主题时出错

spring、kotlin、apache-kafka、spring-kafka、kafka-producer-api

我意识到，当一个新的主题被发表时，如果不存在，就会创建它。因此，当我向Spring创建的新/旧主题发送值时，默认分区为0，但我希望在另一个分区上写入消息，例如分区1。当我在一个主题上创建/写作时，它就是作品： }) ResponseEntity.ok(msg.get(

浏览 0提问于2019-10-03得票数 1

回答已采纳

1回答

DeadLetterPublishingRecoverer -死信发布失败，InvalidTopicException在TopicPartition中的名称主题以_ERR结尾

java、spring-boot、apache-kafka、spring-kafka

org.apache.kafka.clients.Metadata -生产者org.apache.kafka.clients.MetadatatransactionalId=kafka-tx-group1.ABC_TEST_XPTO.0元数据响应报告无效主题: org.apache.kafka.common.errors.InvalidTopicException:无效主题: ABC_TEST_XPTO_ERR 2020-08-05 12:53:10,320: ABC_TEST_XPTO_ERR at org.spring

浏览 7提问于2020-08-05得票数 0

1回答

如何比较两张卡夫卡表？

apache-kafka、apache-kafka-streams、spring-kafka

TOPIC1");现在我有两个表，我需要比较这两个表，而table1中不存在的数据将被发送到另一个kafka主题。

浏览 4提问于2022-09-20得票数 0

回答已采纳

1回答

web仪表板的哪个消息传递系统？

apache-kafka、dashboard、messaging

我想做一个Web仪表板系统，我面临一个问题。我需要在我的程序的一个实例的缓存中得到一个信息，为此，我想用Kafka来做Pub/Sub，但是我不知道如何发布并从我的订阅者那里得到响应。您知道允许这样做的模式和允许我这样做的服务吗？

浏览 9提问于2022-11-07得票数 -1

1回答

Spring集成- kafka出站适配器不接受暴露为spring bean的topic值

spring、apache-kafka、spring-integration、spring-annotations

我已经成功集成了固定主题名称的kafka出站通道适配器。现在，我希望使主题名称可配置，并因此希望通过应用程序属性公开它。<String, String> kafkaTemplate() { }channel="inputToKafka" topic="getTopic"> </int-kafka:outbound-

浏览 2提问于2017-07-27得票数 0

1回答

Spring Kafka重试日志记录

spring-kafka、spring-retry

我有一个要求消费从kafka主题，做一些工作的记录，并产生到另一个主题与spring-kafka 2.1.7。其他要求是事务性的只有一次语义，重试和错误handling.On提交记录失败我应该做3次重试，记录每个重试消息重试主题和失败的所有重试发送记录到一个死信主题。我看过，它有很好的细节来解决这个问题。我正在努力的事情是如何记录每个重试消息的细节，如消费者偏移量，它试图提交的主题，等等.Is有一种方法可以从重试回调？@Bean public RetryListener

浏览 5提问于2018-08-02得票数 0

回答已采纳

1回答

@ConditionalOnBean(KafkaTemplate.class)使整个应用程序崩溃

java、spring、spring-boot、apache-kafka、spring-annotations

我有一个Spring boot应用程序，它使用来自Kafka主题的数据并用从Kafka接收的数据发送电子邮件通知，public EmailService emailService() {EmailServiceImpl(getJavaMailSender());它工作得很好，但是在我添加了@ConditionalOnBean之后@ConditionalOnBean(KafkaTemplate.class我找不到任何解释，这是如何可能的，因为KafkaTemplat

浏览 4提问于2021-08-11得票数 1

1回答

KafkaTemplate生产者发送回调onFailure不调用异常

apache-kafka、spring-kafka

因此，我测试了我的生产者的弹性，我有一个对象，我想发送给kafka (以json格式)，然后根据结果，它将更新我的数据库。我尝试将我的对象发送到一个不存在的主题，我所得到的只是一些错误日志，而且我知道它有异常，因为LoggingProducerListener这么说。我检查了KafkaTemplate的代码，在通知LoggingProducerListener之前，它应该按照预期的方式注册错误。这是代码和日志。final ListenableFuture<SendResult<String, String>> sen

浏览 29提问于2022-05-26得票数 0

1回答

Apache :获取具有关联id 0的主题元数据

apache-kafka

test")) val kafkaHealth = getHealthSink(kafkaHosts, zkHosts) 错误kafka.utils.Utils$从代理ArrayBuffer(id:0，主机：*，端口:9092)获取主题集的主题元数据(id:0，主机：*，端口:9092)失败的kafka.common.KafkaException:从broker ArrayBuffer(id:0，host：*，端口:909

浏览 0提问于2016-09-01得票数 2

回答已采纳

点击加载更多