Had the same problem as Javier's.
3450 [Thread-10] DEBUG
org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Group
metadata response ClientResponse(receivedTimeMs=1455811593680,
disconnected=false, request=ClientRequest(expectResponse=true,
callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@278904b4,
request=RequestSend(header={api_key=10,api_version=0,correlation_id=10,client_id=consumer-4},
body={group_id=test_group}), createdTimeMs=1455811593645,
sendTimeMs=1455811593645),
responseBody={error_code=15,coordinator={node_id=-1,host=,port=-1}})
When Flink consumes Kafka-0.9 locally and the other consumer reads Kafka
cluster both can work.
After reading this -
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Detailed+Consumer+Coordinator+Design#KafkaDetailedConsumerCoordinatorDesign-Consumer
Found that this process is the issue that the consumer co-ordinator cannot
function -
The consumer sends a RegisterConsumer request to it's co-ordinator broker.
In the RegisterConsumerResponse, it receives the list of topic partitions
that it should own.
However we don't know the solution for this yet.
Best,
Sendoh
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Problem-with-Kafka-0-9-Client-tp4975p5029.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
