天天看点

spark消费kafka的时候NetworkClient Using older server API v2 to send LIST_OFFSETS

spark消费kafka的时候NetworkClient Using older server API v2 to send LIST_OFFSETS
19/07/02 19:09:14 DEBUG NetworkClient: [Consumer clientId=consumer-1, groupId=spark-kafka-source-1ba7bac6-2ca9-4150-aef1-c9a17f69d137-1234674426-driver-0] Using older server API v2 to send LIST_OFFSETS {replica_id=-1,isolation_level=0,topics=[{topic=topic_lcc,partitions=[{partition=0,timestamp=-1}]}]} with correlation id 9863 to node 0
19/07/02 19:09:14 DEBUG NetworkClient: [Consumer clientId=consumer-1, groupId=spark-kafka-source-1ba7bac6-2ca9-4150-aef1-c9a17f69d137-1234674426-driver-0] Using older server API v2 to send LIST_OFFSETS {replica_id=-1,isolation_level=0,topics=[{topic=topic_lcc,partitions=[{partition=0,timestamp=-1}]}]} with correlation id 9864 to node 0
19/07/02
           

继续阅读