Hi I have some question about kafka connector: 1) in code i can see *consumer.assign(source.assignedPartitions);* as result 2 client with same group name can't use inner load balancer from kafka
2) other problem "how resume reading kafka after restart". In past we depend on inner kafka mechanism for store offset in kafka/zookeeper, but with KafkaIO i didn't found how i can make this behavior. Additional clarification about processing: sometime we need 2 separate job with same group.id for HA, if one job was killed, second job can start handle messages after rebalance by kafka. Could you help me how we can build our requirement with beam processing? Thans Alexey Diomin
