We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cc767d4 commit 917396dCopy full SHA for 917396d
README.md
@@ -16,11 +16,12 @@ from kafka_bridge_client import KafkaBridgeConsumer
16
17
18
consumer = KafkaBridgeConsumer(
19
- CONFIG['topics']['name'],
20
- group_id=CONFIG['group_id'],
+ 'topic1',
+ 'topic2',
21
+ group_id='my-group,
22
auto_offset_reset='earliest',
23
enable_auto_commit=False,
- bootstrap_server=CONFIG['kafka_bridge']['url'],
24
+ bootstrap_server='your-kafka-bridge-url',
25
consumer_name='consumer-name',
26
)
27
0 commit comments