我对消息传递和aapache kafka都是新手，我不知道在哪种情况下使用哪种消费者api，我看到有两个客户机库可用
Kafka2.11 0.10.11和Kafka客户-0.10.1.1
第一个有点
ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector...
consumer.createMessageStreams...第二个呢
KafkaConsumer<K,V> consumer = new KafkaConsumer<>(properties);
consumer.subscribe(...这两个api服务器的用途不同吗？
1条答案
按热度按时间brccelvz1#
您应该使用kafka客户机库中的实现。主kafka库中的实现仍然是旧的实现，在将来的版本中可能会被删除。