我的应用程序需要将不同的记录发送到不同的主题。我的应用程序正在使用同样的Kafka集群。由于应用程序使用相同的Kafka集群,创建一个生产者工厂就足够了(如果需要更多的话,请告诉我)。
在我看来,我有两个选择。
对两个主题使用相同的kafkaTemplate,并按以下主题调用send方法(请假定我使用了春季默认的Kafka生产者配置)。在这里,我们需要为每个调用传递主题&对于多个主题,我们使用相同的Kafka模板。
class ProducerService {
@Autowired
private KafkaTemplate<GenericRecord, Gen
以下是有效的ruby代码吗?Intellij不这么认为。我已经向intellij提交了一份罚单,但我想确保我的代码是正确的。
我知道它不会做任何事情,但是intellij告诉我attr_reader是未知的,所以我很困惑。
class Person
attr_reader :first_name, :last_name
def initialize
@first_name = nil
@last_name = nil
end
end
我问的原因是intellij将attr_reader突出显示为红色,这通常是一个语法错误。我把所有的时间都花在了Java和Scala
@Configuration
public class KafkaConfiguration {
@Value("${kafka.boot.server}")
private String kafkaServer;
@Bean
public KafkaTemplate<String,String> kafkaTemplate(){
return new KafkaTemplate<>(producerConfig());}
@Bean
public ProducerFactory<S
我需要向Apache主题发送(Post) Json有效负载,但我收到了以下错误:- "message":“无法将com.xyz.User类的值转换为value.serializer中指定的类value.serializer"
此外,Spring显示类强制转换异常:- java.lang.ClassCastException: com.xyz.User不能转换为java.lang.String
下面是我的模式,kafka配置和控制器
public class User {
private String firstname;
private String e
当在kafka侦听器容器中生成消息时,我会得到这个异常。
javax.management.InstanceAlreadyExistsException: kafka.producer:type=app-info,id=producer-tx-group.topicA.1
org.apache.kafka.common.errors.ProducerFencedException: The producer has been rejected from the broker because it tried to use an old epoch with the transactionalI
我有一个卡夫卡的消费者。它消耗了一根线。基于字符串,我们将其转换为不同的avro对象,并将它们发布到不同的主题。我们需要EOS,我们得到的问题是生产者标记为@Primary,但是没有主作品的生产者会失败,下面的错误如下。这两种情况都有安排吗?
KafkaConsumer
@Configuration
public class KafkaConsumerConfig {
@Value("${kafka.server}")
String server;
@Value("${kafka.consumer.groupid}")
S