RdKafka.md

Kafka插件

介绍

• Kafka消费者插件

依赖

• rabbit/rdkafka
• php-rdkafka

配置

• Kafka组件配置

return [
    'kafka' => [
      '{}' => KafkaManager::class
    ]
];

• 插件配置

source_kafka:
  type: Rabbit\Data\Pipeline\Sources\Kafka
  start: true
  topic: test
  dsn: localhost:9092, localhost:9093, localhost:9094
  options:
    GroupId: ck1
    BrokerVersion: 1.0.0
    OffsetReset: earliest
    MetadataRefreshIntervalMs: 10000

sink_kafka:
  type: Rabbit\Data\Pipeline\Sinks\Kafka
  topic: test
  topicSet: 
    acks: '0'
  dsn: localhost:9092, localhost:9093, localhost:9094
  options:
    socket.keepalive.enable: 'true'

• topic消息主题
• dsnkaaka服务器地址
• options & topicSet参考:https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md