Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add Kafka event bus integration #5034

Merged
merged 3 commits into from
Aug 29, 2020
Merged

Add Kafka event bus integration #5034

merged 3 commits into from
Aug 29, 2020

Conversation

realLiangshiwei
Copy link
Member

@realLiangshiwei realLiangshiwei commented Aug 12, 2020

Resolve #4222

Configuration:

"Kafka": {
  "Connections": {
    "Default": {
      "BootstrapServers": "localhost:9092"
    }
  },
  "EventBus": {
    "GroupId": "groupId",
    "TopicName": "topicName"
  }
}

docker-compose.yml

version: '3'

services:
  zoo1:
    image: wurstmeister/zookeeper
    hostname: zoo1
    ports:
      - "2181:2181"
    container_name: zookeeper
  kafka1:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: Your host ip
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://Your host ip:9092
      KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181"
      KAFKA_ADVERTISED_PORT: 9092
      KAFKA_BROKER_ID: 1
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    depends_on:
      - zoo1
    container_name: kafka1

  kafka2:
    image: wurstmeister/kafka
    ports:
      - "9093:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: Your host ip
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://Your host ip:9093
      KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181"
      KAFKA_ADVERTISED_PORT: 9093
      KAFKA_BROKER_ID: 2
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    depends_on:
      - zoo1
    container_name: kafka2

  kafka-manager:
    image: sheepkiller/kafka-manager
    environment:
        ZK_HOSTS: "zoo1:2181"
    ports:
      - "9000:9000"
    container_name: kafkamanager

@realLiangshiwei realLiangshiwei added this to the 3.2 milestone Aug 12, 2020
@realLiangshiwei realLiangshiwei marked this pull request as draft August 12, 2020 12:32
@realLiangshiwei realLiangshiwei marked this pull request as ready for review August 14, 2020 07:12
@hikalkan hikalkan requested a review from maliming August 24, 2020 17:24
@hikalkan hikalkan merged commit 120804d into dev Aug 29, 2020
@hikalkan hikalkan deleted the liangshiwei/Eventbus-kafka branch August 29, 2020 13:37
@hikalkan
Copy link
Member

Thanks. In addition;

Please create separate issues for the last 2 items.

@hikalkan
Copy link
Member

I created the issues:

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Kafka integration for the Distributed Event Bus
2 participants