天天看點

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
           

繼續閱讀