如何沉题,Kafka到Kafka,用Flume?

6ioyuze2  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(402)

我正在尝试将日志从一个主题转移到另一个主题。我需要用Flume把Kafka和Kafka连接起来。请看下面:

  1. #
  2. # Flume Conf
  3. #
  4. a1.sources = s1
  5. a1.sinks = k1
  6. a1.channels = c1
  7. # Kafka Source
  8. a1.sources.s1.type = org.apache.flume.source.kafka.KafkaSource
  9. a1.sources.s1.kafka.bootstrap.servers = kafka:9092
  10. a1.sources.s1.kafka.topics = apache
  11. # Kafka Sink
  12. a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink
  13. a1.sinks.k1.kafka.bootstrap.servers = kafka:9092
  14. # Use a channel which buffers events in memory
  15. a1.channels.c1.type = memory
  16. a1.channels.c1.capacity = 10000000
  17. a1.channels.c1.transactionCapacity = 1000000
  18. # Bind the source and sink to the channel
  19. a1.sources.s1.channels = c1
  20. a1.sinks.k1.channel = c1

Flume没有形成。

uwopmtnx

uwopmtnx1#

如果要将数据从一个kafka群集复制到另一个群集,有比flume更好的方法,包括:
mirrormaker,正如@cricket\u007所提到的(开源,apachekafka的一部分)
confluent's replicator(商业工具,30天免费试用)
ureplicator(uber开源)
mirus(从salesforce开源)
brucke(开源)
如果你想要一个真正肮脏的黑客,你也可以做一些事情 kafkacat 以及 nc .
免责声明:我为confluent工作。

相关问题