API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jun 29th, 2017
803
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 39.94 KB | None | 0 0
raw download clone embed print report
  1. 2017-06-29 17:28:16,215 DEBUG [AbstractCoordinator] - [scheduler-1] - Sending JoinGroup ((type: JoinGroupRequest, groupId=ingestion-matching-kafka-consumer-group-dev1, sessionTimeout=30000, rebalanceTimeout=43200000, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@b45e5583)) to coordinator kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2147483644 rack: null)
  2. 2017-06-29 17:28:16,260 DEBUG [Selector] - [scheduler-1] - Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483644
  3. 2017-06-29 17:28:16,262 DEBUG [NetworkClient] - [scheduler-1] - Completed connection to node 2147483644. Fetching API versions.
  4. 2017-06-29 17:28:16,318 DEBUG [SslTransportLayer] - [scheduler-1] - SSL handshake completed successfully with peerHost 'kafka04-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  5. 2017-06-29 17:28:16,323 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  6. 2017-06-29 17:28:16,569 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Set SASL client state to INITIAL
  7. 2017-06-29 17:28:16,571 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Set SASL client state to INTERMEDIATE
  8. 2017-06-29 17:28:16,624 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Set SASL client state to COMPLETE
  9. 2017-06-29 17:28:16,625 DEBUG [NetworkClient] - [scheduler-1] - Initiating API versions fetch from node 2147483644.
  10. 2017-06-29 17:28:16,681 DEBUG [NetworkClient] - [scheduler-1] - Recorded API versions for node 2147483644: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  11. 2017-06-29 17:29:13,815 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 1 for sending metadata request
  12. 2017-06-29 17:29:13,815 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 1 at kafka02-prod01.messagehub.services.us-south.bluemix.net:9093.
  13. 2017-06-29 17:29:13,938 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  14. 2017-06-29 17:29:13,938 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka02-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  15. 2017-06-29 17:29:14,003 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-1.bytes-sent
  16. 2017-06-29 17:29:14,003 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-1.bytes-received
  17. 2017-06-29 17:29:14,004 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-1.latency
  18. 2017-06-29 17:29:14,004 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 1
  19. 2017-06-29 17:29:14,005 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 1. Fetching API versions.
  20. 2017-06-29 17:29:14,005 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 6 for sending metadata request
  21. 2017-06-29 17:29:14,006 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 6 at kafka07-prod01.messagehub.services.us-south.bluemix.net:9093.
  22. 2017-06-29 17:29:14,007 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  23. 2017-06-29 17:29:14,008 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka07-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  24. 2017-06-29 17:29:14,072 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka02-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  25. 2017-06-29 17:29:14,073 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  26. 2017-06-29 17:29:14,084 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-6.bytes-sent
  27. 2017-06-29 17:29:14,085 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-6.bytes-received
  28. 2017-06-29 17:29:14,086 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-6.latency
  29. 2017-06-29 17:29:14,086 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 6
  30. 2017-06-29 17:29:14,087 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 6. Fetching API versions.
  31. 2017-06-29 17:29:14,087 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 0 for sending metadata request
  32. 2017-06-29 17:29:14,087 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 0 at kafka01-prod01.messagehub.services.us-south.bluemix.net:9093.
  33. 2017-06-29 17:29:14,211 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  34. 2017-06-29 17:29:14,212 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka01-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  35. 2017-06-29 17:29:14,288 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-0.bytes-sent
  36. 2017-06-29 17:29:14,289 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-0.bytes-received
  37. 2017-06-29 17:29:14,289 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-0.latency
  38. 2017-06-29 17:29:14,290 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0
  39. 2017-06-29 17:29:14,290 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 0. Fetching API versions.
  40. 2017-06-29 17:29:14,291 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 3 for sending metadata request
  41. 2017-06-29 17:29:14,291 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 3 at kafka04-prod01.messagehub.services.us-south.bluemix.net:9093.
  42. 2017-06-29 17:29:14,293 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  43. 2017-06-29 17:29:14,294 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka04-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  44. 2017-06-29 17:29:14,297 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka07-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  45. 2017-06-29 17:29:14,298 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  46. 2017-06-29 17:29:14,347 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-3.bytes-sent
  47. 2017-06-29 17:29:14,347 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-3.bytes-received
  48. 2017-06-29 17:29:14,348 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-3.latency
  49. 2017-06-29 17:29:14,349 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 3
  50. 2017-06-29 17:29:14,349 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 3. Fetching API versions.
  51. 2017-06-29 17:29:14,369 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 8 for sending metadata request
  52. 2017-06-29 17:29:14,369 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 8 at kafka09-prod01.messagehub.services.us-south.bluemix.net:9093.
  53. 2017-06-29 17:29:14,506 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  54. 2017-06-29 17:29:14,506 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka09-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  55. 2017-06-29 17:29:14,508 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  56. 2017-06-29 17:29:14,508 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  57. 2017-06-29 17:29:14,510 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka01-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  58. 2017-06-29 17:29:14,511 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  59. 2017-06-29 17:29:14,512 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka04-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  60. 2017-06-29 17:29:14,514 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  61. 2017-06-29 17:29:14,528 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  62. 2017-06-29 17:29:14,529 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  63. 2017-06-29 17:29:14,583 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-8.bytes-sent
  64. 2017-06-29 17:29:14,584 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-8.bytes-received
  65. 2017-06-29 17:29:14,585 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-8.latency
  66. 2017-06-29 17:29:14,585 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 8
  67. 2017-06-29 17:29:14,586 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 8. Fetching API versions.
  68. 2017-06-29 17:29:14,586 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 7 for sending metadata request
  69. 2017-06-29 17:29:14,586 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 7 at kafka08-prod01.messagehub.services.us-south.bluemix.net:9093.
  70. 2017-06-29 17:29:14,588 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  71. 2017-06-29 17:29:14,589 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka08-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  72. 2017-06-29 17:29:14,606 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  73. 2017-06-29 17:29:14,606 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 6.
  74. 2017-06-29 17:29:14,642 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-7.bytes-sent
  75. 2017-06-29 17:29:14,642 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-7.bytes-received
  76. 2017-06-29 17:29:14,643 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-7.latency
  77. 2017-06-29 17:29:14,644 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 7
  78. 2017-06-29 17:29:14,644 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 7. Fetching API versions.
  79. 2017-06-29 17:29:14,668 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initialize connection to node 5 for sending metadata request
  80. 2017-06-29 17:29:14,668 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating connection to node 5 at kafka06-prod01.messagehub.services.us-south.bluemix.net:9093.
  81. 2017-06-29 17:29:14,670 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  82. 2017-06-29 17:29:14,670 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka06-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
  83. 2017-06-29 17:29:14,685 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 6: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  84. 2017-06-29 17:29:14,686 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Sending metadata request (type=MetadataRequest, topics=) to node 6
  85. 2017-06-29 17:29:14,747 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-5.bytes-sent
  86. 2017-06-29 17:29:14,748 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-5.bytes-received
  87. 2017-06-29 17:29:14,748 DEBUG [Metrics] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Added sensor with name node-5.latency
  88. 2017-06-29 17:29:14,748 DEBUG [Selector] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 5
  89. 2017-06-29 17:29:14,749 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Completed connection to node 5. Fetching API versions.
  90. 2017-06-29 17:29:14,760 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka08-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  91. 2017-06-29 17:29:14,761 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  92. 2017-06-29 17:29:14,762 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka09-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  93. 2017-06-29 17:29:14,764 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  94. 2017-06-29 17:29:14,764 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  95. 2017-06-29 17:29:14,765 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  96. 2017-06-29 17:29:14,766 DEBUG [Metadata] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Updated cluster metadata version 3 to Cluster(id = nxre3ZDoSL6te6OUNclnFA, nodes = [kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null), kafka02-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 1 rack: null), kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 3 rack: null), kafka03-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2 rack: null), kafka07-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 6 rack: null), kafka09-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 8 rack: null), kafka08-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 7 rack: null), kafka05-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 4 rack: null), kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 0 rack: null)], partitions = [])
  97. 2017-06-29 17:29:14,895 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  98. 2017-06-29 17:29:14,896 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  99. 2017-06-29 17:29:14,911 DEBUG [SslTransportLayer] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - SSL handshake completed successfully with peerHost 'kafka06-prod01.messagehub.services.us-south.bluemix.net' peerPort 9093 peerPrincipal 'CN=*.messagehub.services.us-south.bluemix.net, O=International Business Machines Corporation, L=Armonk, ST=New York, C=US' cipherSuite 'SSL_ECDHE_RSA_WITH_AES_128_GCM_SHA256'
  100. 2017-06-29 17:29:14,913 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to RECEIVE_HANDSHAKE_RESPONSE
  101. 2017-06-29 17:29:14,920 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  102. 2017-06-29 17:29:14,920 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 1.
  103. 2017-06-29 17:29:14,988 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  104. 2017-06-29 17:29:15,000 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  105. 2017-06-29 17:29:15,000 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  106. 2017-06-29 17:29:15,054 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  107. 2017-06-29 17:29:15,055 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 7.
  108. 2017-06-29 17:29:15,057 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  109. 2017-06-29 17:29:15,058 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  110. 2017-06-29 17:29:15,111 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 7: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  111. 2017-06-29 17:29:15,157 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INITIAL
  112. 2017-06-29 17:29:15,158 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to INTERMEDIATE
  113. 2017-06-29 17:29:15,161 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  114. 2017-06-29 17:29:15,162 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 3.
  115. 2017-06-29 17:29:15,217 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 3: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  116. 2017-06-29 17:29:15,236 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  117. 2017-06-29 17:29:15,237 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 5.
  118. 2017-06-29 17:29:15,315 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 5: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  119. 2017-06-29 17:29:15,317 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  120. 2017-06-29 17:29:15,318 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 0.
  121. 2017-06-29 17:29:15,469 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 0: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  122. 2017-06-29 17:29:15,482 DEBUG [SaslClientAuthenticator] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Set SASL client state to COMPLETE
  123. 2017-06-29 17:29:15,483 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Initiating API versions fetch from node 8.
  124. 2017-06-29 17:29:15,562 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Recorded API versions for node 8: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0])
  125. 2017-06-29 17:33:15,564 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Node -4 disconnected.
  126. 2017-06-29 17:33:15,567 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Sending metadata request (type=MetadataRequest, topics=) to node 0
  127. 2017-06-29 17:33:15,571 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Node -5 disconnected.
  128. 2017-06-29 17:33:15,653 DEBUG [Metadata] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Updated cluster metadata version 4 to Cluster(id = nxre3ZDoSL6te6OUNclnFA, nodes = [kafka07-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 6 rack: null), kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 0 rack: null), kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null), kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 3 rack: null), kafka09-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 8 rack: null), kafka02-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 1 rack: null), kafka05-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 4 rack: null), kafka08-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 7 rack: null), kafka03-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2 rack: null)], partitions = [])
  129. 2017-06-29 17:33:15,658 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Node -1 disconnected.
  130. 2017-06-29 17:33:15,753 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Node -2 disconnected.
  131. 2017-06-29 17:33:15,755 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Sending metadata request (type=MetadataRequest, topics=) to node 3
  132. 2017-06-29 17:33:15,759 DEBUG [NetworkClient] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Node -3 disconnected.
  133. 2017-06-29 17:33:15,815 DEBUG [Metadata] - [kafka-producer-network-thread | ingestion-matching-kafka-producer] - Updated cluster metadata version 5 to Cluster(id = nxre3ZDoSL6te6OUNclnFA, nodes = [kafka08-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 7 rack: null), kafka03-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2 rack: null), kafka07-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 6 rack: null), kafka02-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 1 rack: null), kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 0 rack: null), kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null), kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 3 rack: null), kafka05-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 4 rack: null), kafka09-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 8 rack: null)], partitions = [])
  134. 2017-06-29 17:33:16,069 DEBUG [NetworkClient] - [scheduler-1] - Node 7 disconnected.
  135. 2017-06-29 17:33:16,071 DEBUG [NetworkClient] - [scheduler-1] - Sending metadata request (type=MetadataRequest, topics=dev1-to-process) to node 6
  136. 2017-06-29 17:33:16,158 DEBUG [Metadata] - [scheduler-1] - Updated cluster metadata version 7 to Cluster(id = nxre3ZDoSL6te6OUNclnFA, nodes = [kafka05-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 4 rack: null), kafka02-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 1 rack: null), kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null), kafka07-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 6 rack: null), kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 3 rack: null), kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 0 rack: null), kafka09-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 8 rack: null), kafka03-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2 rack: null), kafka08-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 7 rack: null)], partitions = [Partition(topic = dev1-to-process, partition = 11, leader = 0, replicas = [0,7,8], isr = [7,8,0]), Partition(topic = dev1-to-process, partition = 10, leader = 8, replicas = [6,7,8], isr = [8,6,7]), Partition(topic = dev1-to-process, partition = 9, leader = 7, replicas = [5,6,7], isr = [7,5,6]), Partition(topic = dev1-to-process, partition = 8, leader = 6, replicas = [6,3,4], isr = [6,3,4]), Partition(topic = dev1-to-process, partition = 15, leader = 4, replicas = [2,3,4], isr = [4,2,3]), Partition(topic = dev1-to-process, partition = 14, leader = 3, replicas = [1,2,3], isr = [3,1,2]), Partition(topic = dev1-to-process, partition = 13, leader = 2, replicas = [0,1,2], isr = [2,1,0]), Partition(topic = dev1-to-process, partition = 12, leader = 1, replicas = [0,1,8], isr = [1,8,0]), Partition(topic = dev1-to-process, partition = 3, leader = 1, replicas = [1,7,8], isr = [1,7,8]), Partition(topic = dev1-to-process, partition = 2, leader = 0, replicas = [0,6,7], isr = [6,7,0]), Partition(topic = dev1-to-process, partition = 1, leader = 8, replicas = [5,6,8], isr = [8,5,6]), Partition(topic = dev1-to-process, partition = 0, leader = 7, replicas = [5,7,4], isr = [7,4,5]), Partition(topic = dev1-to-process, partition = 7, leader = 5, replicas = [5,2,3], isr = [5,2,3]), Partition(topic = dev1-to-process, partition = 6, leader = 4, replicas = [1,2,4], isr = [4,1,2]), Partition(topic = dev1-to-process, partition = 5, leader = 3, replicas = [0,1,3], isr = [3,1,0]), Partition(topic = dev1-to-process, partition = 4, leader = 2, replicas = [0,2,8], isr = [2,8,0])])
  137. 2017-06-29 17:37:16,168 DEBUG [NetworkClient] - [scheduler-1] - Node 2 disconnected.
  138. 2017-06-29 17:37:16,171 DEBUG [NetworkClient] - [scheduler-1] - Sending metadata request (type=MetadataRequest, topics=dev1-to-process) to node 5
  139. 2017-06-29 17:37:16,175 DEBUG [NetworkClient] - [scheduler-1] - Node 3 disconnected.
  140. 2017-06-29 17:37:16,256 DEBUG [Metadata] - [scheduler-1] - Updated cluster metadata version 8 to Cluster(id = nxre3ZDoSL6te6OUNclnFA, nodes = [kafka08-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 7 rack: null), kafka03-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2 rack: null), kafka09-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 8 rack: null), kafka07-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 6 rack: null), kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 3 rack: null), kafka01-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 0 rack: null), kafka05-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 4 rack: null), kafka02-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 1 rack: null), kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null)], partitions = [Partition(topic = dev1-to-process, partition = 11, leader = 0, replicas = [0,7,8], isr = [7,8,0]), Partition(topic = dev1-to-process, partition = 10, leader = 8, replicas = [6,7,8], isr = [8,6,7]), Partition(topic = dev1-to-process, partition = 9, leader = 7, replicas = [5,6,7], isr = [7,5,6]), Partition(topic = dev1-to-process, partition = 8, leader = 6, replicas = [6,3,4], isr = [6,3,4]), Partition(topic = dev1-to-process, partition = 15, leader = 4, replicas = [2,3,4], isr = [4,2,3]), Partition(topic = dev1-to-process, partition = 14, leader = 3, replicas = [1,2,3], isr = [3,1,2]), Partition(topic = dev1-to-process, partition = 13, leader = 2, replicas = [0,1,2], isr = [2,1,0]), Partition(topic = dev1-to-process, partition = 12, leader = 1, replicas = [0,1,8], isr = [1,8,0]), Partition(topic = dev1-to-process, partition = 3, leader = 1, replicas = [1,7,8], isr = [1,7,8]), Partition(topic = dev1-to-process, partition = 2, leader = 0, replicas = [0,6,7], isr = [6,7,0]), Partition(topic = dev1-to-process, partition = 1, leader = 8, replicas = [5,6,8], isr = [8,5,6]), Partition(topic = dev1-to-process, partition = 0, leader = 7, replicas = [5,7,4], isr = [7,4,5]), Partition(topic = dev1-to-process, partition = 7, leader = 5, replicas = [5,2,3], isr = [5,2,3]), Partition(topic = dev1-to-process, partition = 6, leader = 4, replicas = [1,2,4], isr = [4,1,2]), Partition(topic = dev1-to-process, partition = 5, leader = 3, replicas = [0,1,3], isr = [3,1,0]), Partition(topic = dev1-to-process, partition = 4, leader = 2, replicas = [0,2,8], isr = [2,8,0])])
  141. 2017-06-29 17:37:21,261 DEBUG [NetworkClient] - [scheduler-1] - Node 2147483644 disconnected.
  142. 2017-06-29 17:37:21,263 DEBUG [ConsumerNetworkClient] - [scheduler-1] - Cancelled JOIN_GROUP request {api_key=11,api_version=1,correlation_id=19,client_id=ingestion-matching-kafka-consumer-dev1} with correlation id 19 due to node 2147483644 being disconnected
  143. 2017-06-29 17:37:21,265 INFO [AbstractCoordinator] - [scheduler-1] - Marking the coordinator kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2147483644 rack: null) dead for group ingestion-matching-kafka-consumer-group-dev1
  144. 2017-06-29 17:37:21,367 DEBUG [AbstractCoordinator] - [scheduler-1] - Sending GroupCoordinator request for group ingestion-matching-kafka-consumer-group-dev1 to broker kafka06-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 5 rack: null)
  145. 2017-06-29 17:37:21,368 DEBUG [NetworkClient] - [scheduler-1] - Sending metadata request (type=MetadataRequest, topics=dev1-to-process) to node 6
  146. 2017-06-29 17:37:21,447 DEBUG [AbstractCoordinator] - [scheduler-1] - Received GroupCoordinator response ClientResponse(receivedTimeMs=1498772241447, latencyMs=79, disconnected=false, requestHeader={api_key=10,api_version=0,correlation_id=23,client_id=ingestion-matching-kafka-consumer-dev1}, responseBody={error_code=0,coordinator={node_id=3,host=kafka04-prod01.messagehub.services.us-south.bluemix.net,port=9093}}) for group ingestion-matching-kafka-consumer-group-dev1
  147. 2017-06-29 17:37:21,451 INFO [AbstractCoordinator] - [scheduler-1] - Discovered coordinator kafka04-prod01.messagehub.services.us-south.bluemix.net:9093 (id: 2147483644 rack: null) for group ingestion-matching-kafka-consumer-group-dev1.
  148. 2017-06-29 17:37:21,452 DEBUG [NetworkClient] - [scheduler-1] - Initiating connection to node 2147483644 at kafka04-prod01.messagehub.services.us-south.bluemix.net:9093.
  149. 2017-06-29 17:37:21,576 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Set SASL client state to SEND_HANDSHAKE_REQUEST
  150. 2017-06-29 17:37:21,578 DEBUG [SaslClientAuthenticator] - [scheduler-1] - Creating SaslClient: client=null;service=kafka;serviceHostname=kafka04-prod01.messagehub.services.us-south.bluemix.net;mechs=[PLAIN]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!