我正在使用confluent-kafka。": "none",
}) 当运行这段代码时，我得到了 E cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "schema.compatibility.level""
浏览 142提问于2021-09-07得票数 0
2回答
我正在尝试使用Spring Cloud和Kafka Avro序列化程序在Kafka上生成一个事件。在我的application.yml中，我有下面的配置，但是当序列化程序试图生成消息时，它会生成字节，因为在KafkaSerializer中传递给getScheme方法的对象是一个字节数组，而不是GenericRecord我想在Spring Cloud中我需要一个特定的MessageConverter，但是我没有找到。c
浏览 0提问于2018-11-01得票数 0
我们有一个spring boot应用程序，它使用spring-kafka。当我们更新一个配置属性时，我们想要禁用kafka生产者(kafkatemplate)。我尝试过使用条件bean和应用程序上下文刷新。
有没有办法用spring-kafka优雅地关闭kafka生产者？
浏览 7提问于2017-02-02得票数 1
回答已采纳
有没有人知道是否可以将writeStream调用到Kafka主题，其中创建的主题是压缩主题？下面的代码创建了一个Kafka主题，但是传递的选项被忽略了。StreamingQuery query = ds .format("kafka")
.option("kafka.bootstrap.servers", "localh
浏览 0提问于2019-03-18得票数 2
当使用Kafka创建一个完全一次语义的Kafka生产者时，必须设置两个属性：transactional.id必须设置为事务性id，enable.idempotence必须设置为true。在Apache中，可以将FlinkKafkaProducer配置为生产者想要的语义的参数，特别是使用值Semantics.EXACTLY_ONCE精确地配置一次语义。查看FlinkKafkaProd
浏览 4提问于2020-06-09得票数 2
回答已采纳
假设有以下场景：
我在本地启动zookeeper和一个kafka代理，并创建“测试”主题，如kafka快速入门：中所述。然后，我运行一个简单的java程序，该程序每秒生成一条指向"test“主题的消息。一段时间后，我关闭了我的本地kafka代理，看到producer继续生成消息，它没有抛出任何异常。最后，我再次启动kafka broker，producer能够重新连接到broker，并继续生成消息，但是，在kafka bro
浏览 1提问于2018-04-06得票数 1
Kafka有自己的一组配置，可以以编程方式创建主题。
对于生产者(java) API?有类似的东西吗？
浏览 7提问于2022-06-22得票数 2
回答已采纳
来自我的kafka生产者的一些消息超过了默认的1MB，并且被代理拒绝。
我无法访问代理和消费者来进行更改。因此，我只需要在生产者级别进行更改。我正在考虑在我的producer中使用batch.size到5MB的snappy压缩。请让我知道这是否是正确的选择或任何其他方式可用于我的用例。谢谢
浏览 0提问于2020-07-23得票数 0
3回答
我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦Kafka生产者，那么消息将写入没有前导字符/标题的主题：
浏览 1提问于2017-11-21得票数 3
回答已采纳
1回答
我有一个配置服务器和几个与Kafka一起工作的客户端。当我更新配置服务器上的配置属性时，我希望我的客户端不间断地工作。bean with topics, producers and consumers}如果我将bootstrap.servers属性更改为不正确的，并且调用了卡夫卡生产者，就会有一个警告，其中包含
浏览 6提问于2021-11-03得票数 0
我希望测试中的生产者等待测试类中的消费者通过调用Acknowledgement.acknowledge()来确认。我的使用者使用以下属性初始化： kafka: group-id: test-group factory.setConcurrency(numListeners);
r
浏览 5提问于2022-11-19得票数 0
回答已采纳
当辅助模式注册中心(带有leader.eligibility: false)尝试将新的模式注册转发到主模式注册中心时，它会使用主模式注册中心的内部IP，但最终会失败。主架构注册表配置： host.name=10.X.X.X (internal IP of schema registry pod)
kafkastore.group.id=my-schema-registrykafkastore.bootstrap.servers=PLAINTEXT://my-clust
浏览 34提问于2021-09-21得票数 0
回答已采纳
需要帮助理解Kafka中的'acks‘属性，该属性在生产者配置中。 假设我错过了在producer类中传递'acks‘属性。然后，默认情况下，Kafka认为它是‘ack =0’。现在假设我需要有'acks=all‘，这样它才能保证我的消息传递到Kafka broker。有没有什么方法可以确保server.properties文件中的任
浏览 8提问于2019-09-19得票数 1
1回答
卡夫卡数据丢失，在生产者
、、、
我一直试图配置一个卡夫卡经纪人，一个话题，一个生产者，一个消费者。当生产者生产时，如果经纪人倒闭，就会发生数据丢失(如：Datum 1 - published.Datum 5 - publishedbootstrap.servers=localhost:9092retriesval
浏览 4提问于2016-07-27得票数 0
回答已采纳
2回答
将同步副本配置为Acks=all和min.insync.replicas = N，当Kafka无法处理ISR时，在线记录在处理过程中是N-1，最小配置的
浏览 8提问于2021-01-17得票数 0
对于卡夫卡来说，尝试理解卡夫卡的重试概念是很新鲜的。将完成哪些基础重试过程？示例重试参数，我们将其设置为7。现在来问一下，
浏览 11提问于2020-05-04得票数 0
我正在尝试阅读卡夫卡主题中的最后一条消息，使用ConsumerSeekAware.Message类型是Avro列表。我能成功地做到这一点。但在反序列化过程中，它是失败的。这条消息是使用spring云流-kafka框架生成的。消息是avro对象的列表。但是我正在尝试用Avro模式创建datamReader。但是我尝试创建像Schema.createArray(UserDTO.class)这样的模式。但是它不起作用。我认
浏览 4提问于2017-09-28得票数 1
我们正在为Kafka使用，并寻找精确的一次语义。我们有一个很好的解决方案，如预期的那样工作：( 1)使用MetaDataStore检查来自消费者端的重复消息(offsetId + partitionId + topicName)，使用上面的解决方案，我们没有任何消息丢失和重复处理。但是现在我们发现有一个属性(producer.sendOffsetsToTransaction) Kafka帮助我们修复来自消费者端的重复处理，而没
浏览 0提问于2019-03-27得票数 0
回答已采纳
我对Spring Cloud Stream和Kafka都是新手。在有效负载中发送字符串时，我从kafka生产者收到以下错误。任何帮助或见解都是非常感谢的。我尝试使用bytearray序列化程序/反序列化程序以及与纯文本相反的json。错误消息: org.apache.kafka.common.errors.SerializationException:无法将类[B ]的值转换为value.serializer中指定的
浏览 0提问于2019-10-26得票数 1
1回答
我有一个实用程序，我想在Stream应用程序中获得底层的Kafka生产者(KafkaTemplate)。在浏览代码时，我偶然发现了KafkaProducerMessageHandler，它有一个getKafkaTemplate方法。然而，它不能自动连接.此外，如果我直接自动连接KafkaTemplate，模板将使用默认属性初始化，并忽略SCSt配置的binder键中的binder键中的binder。如何访问Strea
浏览 0提问于2020-07-07得票数 1
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
