如何将应用程序属性设置为默认的kafka producer模板，而不使用kafka producer配置bean进行设置

文章/答案/技术大牛

发布

3回答

Kafka生产者JSON序列化

spring、apache-kafka、spring-cloud-stream、spring-kafka

我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦在默认设置下，这是推送到Kafka的消息： contentType

浏览 1提问于2017-11-21得票数 3

回答已采纳

1回答

spring-kafka

下面是使用属性文件定义的应用程序属性：spring.kafka.producer.key-serializer= 1spring.kafka.producer

浏览 13提问于2021-02-18得票数 0

回答已采纳

3回答

Kafka如何将生产者重试次数设置为无穷大

spring-boot、apache-kafka、spring-kafka

如何将spring-boot属性: spring.kafka.producer.retries设置为Integer.MAX_VALUE？是否可以取消设置此属性，或者默认设置为0？@查看KIP 中的默认kafka

浏览 0提问于2018-12-10得票数 4

1回答

Spring Kafka* producer向无效主题发送消息时出现无限循环*

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

我正在开发一个Spring引导应用程序。该应用程序充当Kafka-producer，其中生产/发布消息并不是很重要。我正在使用spring-kafka依赖项，其配置如下 @Bean Map我的应用程序显示以下日志 17:18:45.187 [kafka</

浏览 245提问于2021-08-12得票数 1

1回答

是否有方法为每个主题指定引导服务器和模式注册表？

spring、apache-kafka、spring-kafka

我遇到了一个问题，我在spring中有一个应用程序，这个应用程序从一个主题中消耗，在另一个主题中生成。spring.kafka.bootstrap-servers=localhost:32202 spring.kafka.properties.schema.registry.

浏览 5提问于2022-11-08得票数 0

1回答

=raw spring.cloud.stream.bindings.output.producer.use-native-encoding=true spring.cloud.stream.kafka.streams.bindings.output.producer.keySerde==org.apache.kafka.common.serialization.StringSerializer spring.cloud.stream.kafka.streams.bindings.output.pr

浏览 1提问于2018-11-15得票数 0

回答已采纳

1回答

节点长时间停机，Kafka* Stream停止重新连接*

apache-kafka

我们面临着一个问题，当kafka流在Node长时间关闭后无法重新连接时，我们会收到下面提到的这个错误。Error connecting to node localhost:9093 (id: -7 rack: null), 2021-10-21 00:21:14.567 [kafka-producer-network-thread| producer-135] WARN o.apache.kafka.clients.NetworkClient.initiateConnect - [<e

浏览 0提问于2021-10-21得票数 0

0回答

Confluent Kafka* Python库为批量消息配置生产者*

python、apache-kafka、kafka-producer-api、confluent-platform

我需要设置Kafka生产者发送一批500个味精，而不是味精，而是批量导入。)所以我深入研究，发现我必须在生产者配置中将类型设置为async，并将batch.size设置为大于默认值，但当我尝试如下配置时： from confluent_kafka import Con

浏览 12提问于2017-06-15得票数 0

回答已采纳

5回答

如何使用kafka-控制台-生成器生成消息到选定的分区？

apache-kafka

根据卡夫卡的文件：我想在消息发送时指定某种“分区id”。

浏览 5提问于2014-10-24得票数 21

回答已采纳

1回答

如何在属性文件弹簧引导中设置Acks=all

spring-boot、apache-kafka、spring-cloud-stream

我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和 spring.cloud.stream.kafka.streams.bindings.<channel>.<em

浏览 1提问于2019-04-24得票数 1

3回答

Kafka:序列化后的消息大于您用max.request.size配置配置的最大请求大小

apache-kafka、kafka-consumer-api、kafka-producer-api、spring-kafka

获取以下错误(Kafka 2.1.0)： 2018-12-03 21:22:37.873错误37645 -- nio-8080-exec-1 o.s.k.support.LoggingProducerListener‘时抛出的异常要主题为org.apache.kafka.common.errors.RecordTooLargeException：：recieved_sound，序列化时消息为1269892字节，比您用max.request.size配置配置的最大请求大

浏览 0提问于2018-12-04得票数 11

1回答

泉云流卡夫卡误码信道

java、spring、spring-cloud-stream、spring-kafka

我的配置： cloud: kafka: accountOut.producer:我正在使用一个@StreamListener(target = "kieran-error")和配置为@Input("kieran-error") SubscribableChannel的使用者侦听我正在<

浏览 0提问于2018-03-09得票数 0

回答已采纳

2回答

如何由Alpakka创建多个分区

apache-kafka、kafka-producer-api、alpakka

我正在尝试创建一个简单的生成器，它用配置提供的一些分区创建一个主题。根据，来自org.apache.kafka.clients.producer.ProducerConfig的任何属性都可以在kafka-clients部分中设置。并且，有一个num.partitions属性，如中的注释。因此，我将该属性添加到我的application.conf文件中，如下所示：

浏览 2提问于2019-04-04得票数 0

回答已采纳

1回答

如何为合流模式注册表配置主题命名策略？

apache-kafka、avro、confluent-schema-registry

因此，您现在可以选择使用confluent.key.subject.name.strategy和confluent.value.subject.name.strategy将模式主题键和值配置为默认的命名策略而不是默认的命名策略，使用kafka-avro-console-producer通过属性value.subject.name.strategy编写记录给卡夫卡，就像这个建议<em

浏览 11提问于2020-10-31得票数 2

回答已采纳

1回答

如何使RetryAdvice为KafkaProducerMessageHandler工作

java、spring-boot、spring-integration、spring-kafka

我正在尝试为Kafka处理程序编写Kafka；然后回到将MongoDB保存为RecoveryCallback。;@TestPropertySource(properties = {为Kafka添加了调试日志，我注意到生产者进入了一个循环，试图在一个单独的线程中重新连接Kafka

浏览 3提问于2021-03-23得票数 2

回答已采纳

1回答

在事务中包装StreamBridge发送和JPA保存

spring-boot、spring-kafka、spring-cloud-stream、spring-cloud-stream-binder-kafka

我试图包装一个rest服务调用，它使用JPA (CrudRepository.save)将记录保存到DB，然后使用StreamBridge使用spring云流(kafka binder)将消息发送到Kafka我故意造成JPA问题(插入违反唯一键约束的行)，但是Kafka消息似乎仍然传递给代理。我已经配置了一个KafkaTransactionManager (没有使用ChainedKafkaTransactionManager，因为现在

浏览 2提问于2021-07-20得票数 4

回答已采纳

2回答

弹簧启动卡夫卡消费者投球误差循环

spring-boot、apache-kafka、spring-kafka

我不面临任何问题，如果我运行任何生产者或消费者在一个终端，而另一个在春季启动。这个错误发生在无限循环中(当生产者和使用者都从不同的spring引导项目启动时)： at java.base/java.lang.Thread.run(Thread.java

浏览 9提问于2021-03-29得票数 1

回答已采纳

1回答

使用spring云流向错误通道发送错误消息

spring-integration、spring-cloud-stream、spring-kafka

我正在使用spring -cloud-stream:1.3.0开发spring启动应用程序。messages，spring-cloud-stream-binder-kafka:1.3.0.RELEASE.我使用spring集成dsl来拆分文件中的行，并使用beanio将行转换为json，要求将成功的下面是application.yml中的配置。设置为true时创建PublishSubscribeCh

浏览 2提问于2017-10-19得票数 1

2回答

如何使用Kafka节点将AWS Bitnami认证kafka* AMI与弹性Bean秸秆nodejs环境连接*

node.js、amazon-web-services、apache-kafka、amazon-elastic-beanstalk、amazon-vpc

我试图使用连接与Elastic环境，如何做到这一点？zookeeper.connect=<Public DNS (IPv4) from AWS>:2181var Producer =kafka.Producer</

浏览 0提问于2019-06-18得票数 4

1回答

启用kafka源连接器幂等性

apache-kafka、apache-kafka-connect

如何开启Kafka源连接器幂等性功能？我知道在confluent中，我们可以通过worker配置中的producer.*属性覆盖生产者配置，但是Kafka本身呢？是一样的吗？设置这些配置后，我可以在哪里看到我的connect worker的应用配置？

浏览 1提问于2021-01-22得票数 1

点击加载更多

Kafka生产者JSON序列化