yunfeng79 opened a new pull request #11507:
URL: https://github.com/apache/kafka/pull/11507
CentOS 7.9
kafka_2.13-2.7.0
kafka cluster
IP:192.168.0.xx
192.168.0.xx
192.168.0.xx
Error log:
[2021-11-15 11:13:01,762] INFO Terminating process due to signal SIGTERM
(org.apache.kafka.common.utils.LoggingSignalHandler)
[2021-11-15 11:13:01,767] INFO [KafkaServer id=1] shutting down
(kafka.server.KafkaServer)
[2021-11-15 11:13:01,774] INFO [KafkaServer id=1] Starting controlled
shutdown (kafka.server.KafkaServer)
[2021-11-15 11:13:01,845] INFO [ReplicaFetcherManager on broker 1] Removed
fetcher for partitions
HashSet(normal-event-project-bf2421b9ec2b48219d3d161aa50d9ebb-0,
normal-event-project-856932a7e5404249bd8178be80fd809c-0,
event-with-wrong-prop-project-377e3bd74fe74a98bbaa5e9639ed6d93-0,
topsense-flink-event-1399648264327925760-reg-0,
abnormal-event-project-cc188cecb5dc448182b8d5d94ef58023-0,
topsense-exception-0, normal-event-project-873bb169b83848b19f8739f96b95f098-0,
abnormal-event-project-283cbef60c8c4363b9d9c03ddb98fcf8-0,
event-with-wrong-prop-project-9687fcf0dedd4a3382cea74a09317716-0,
normal-event-project-44b7faa09eab496682eae2835c935b43-0,
received-data-project-56e11bbe731345f9b234f28a35936acd-0,
original-data-project-bf2421b9ec2b48219d3d161aa50d9ebb-0,
abnormal-event-project-w-0,
abnormal-event-project-bfc0fe135a194c5a88cc1006294ef7c2-0,
event-with-wrong-prop-project-7b9e3bb645ca49919e8e714bd8f05a54-0,
received-data-project-3bdb32eb00004c4291fcee0a23859d19-0, original-data-
project-7cb655bcc9744908843dd4b85e721c36-0,
original-data-project-1410475991847014400-0,
received-data-project-64e023c29b714ed2986fde59dac5935c-0,
dongxin_final_account_pay-0, normal-event-0,
topsense-flink-event-1410475631933788160-reg-0,
event-with-wrong-prop-project-070a88750b2c4febb138151b3efcbd47-0,
original-data-0,
event-with-wrong-prop-project-64e023c29b714ed2986fde59dac5935c-0,
original-data-project-283cbef60c8c4363b9d9c03ddb98fcf8-0,
original-data-project-856932a7e5404249bd8178be80fd809c-0,
original-data-project-8c85bb45585e4304b975b6683c94c889-0,
received-data-project-1382362631821725696-0,
event-with-wrong-prop-project-b7fd666219d34e589862ecbadda36c82-0,
abnormal-event-project-1382362631821725696-0,
event-with-wrong-prop-project-3648e1cd8cf84348942d115255a1817a-0,
topsense-flink-event-1410475631933788160-pay-0,
received-data-project-44b7faa09eab496682eae2835c935b43-0,
event-with-wrong-prop-project-bfc0fe135a194c5a88cc1006294ef7c2-0,
normal-event-project-140727806083059302
4-0, event-with-wrong-prop-project-41a479f83af34e1189cced159f8210d0-0,
original-data-project-1399648264327925760-0,
received-data-project-b7016b06e96e4fefa55fac08c6980872-0,
normal-event-project-7b9e3bb645ca49919e8e714bd8f05a54-0,
received-data-project-05ceaec87673424a9d442bee5182c533-0,
received-data-project-856932a7e5404249bd8178be80fd809c-0,
normal-event-project-377e3bd74fe74a98bbaa5e9639ed6d93-0,
abnormal-event-project-9687fcf0dedd4a3382cea74a09317716-0,
debezium_dws_dongxin_daily_kpi-0, normal-event-project-1111111-0,
normal-event-project-1403170430596026368-0,
received-data-project-710b618c371341ebb8eaafe8131724ce-0,
event-with-wrong-prop-project-e239dd677edb4af0a71b4c3101ca3e56-0,
event-with-wrong-prop-project-873bb169b83848b19f8739f96b95f098-0,
received-data-project-e80344cbd81b46a899bebd5a8fa442e2-0,
original-data-project-e239dd677edb4af0a71b4c3101ca3e56-0,
received-data-project-2a284018298f46e7a9a29a98194c1c28-0,
abnormal-event-project-3bdb32eb00004c4291fcee0a23859d19-0, o
riginal-data-project-377e3bd74fe74a98bbaa5e9639ed6d93-0,
dongxin_retry_account_reg_retention-0,
normal-event-project-036f1cd216734ae3bd53017fbb3b2741-0,
abnormal-event-project-8c85bb45585e4304b975b6683c94c889-0,
event-with-wrong-prop-project-b18756b9715b4728bc3fb3fbc17b6a00-0,
normal-event-project-1382362631821725696-0,
received-data-project-377e3bd74fe74a98bbaa5e9639ed6d93-0,
original-data-project-w-0,
normal-event-project-9687fcf0dedd4a3382cea74a09317716-0,
event-with-wrong-prop-project-w-0,
abnormal-event-project-e80344cbd81b46a899bebd5a8fa442e2-0,
debezium_dwd_dongxin_account_reg-0,
topsense-flink-event-1410475631933788160-login-0,
event-with-wrong-prop-project-7cb655bcc9744908843dd4b85e721c36-0,
event-with-wrong-prop-project-1399648264327925760-0,
event-with-wrong-prop-project-1408268520894107648-0,
received-data-project-1407297406042771456-0,
original-data-project-b7fd666219d34e589862ecbadda36c82-0,
received-data-project-cc188cecb5dc448182b8d5d94ef58023-0, original-data-projec
t-8814c981968b40928c03b74e100507c0-0,
received-data-project-9687fcf0dedd4a3382cea74a09317716-0,
abnormal-event-project-1407297406042771456-0,
abnormal-event-project-b18756b9715b4728bc3fb3fbc17b6a00-0,
normal-event-project-48edd0d91da647dbbf4b070b66c607bd-0,
event-with-wrong-prop-project-856932a7e5404249bd8178be80fd809c-0,
event-with-wrong-prop-project-44b7faa09eab496682eae2835c935b43-0,
received-data-project-1407297168498364416-0)
(kafka.server.ReplicaFetcherManager)
[2021-11-15 11:13:01,905] INFO [KafkaServer id=1] Controlled shutdown
succeeded (kafka.server.KafkaServer)
[2021-11-15 11:13:01,912] INFO [/config/changes-event-process-thread]:
Shutting down
(kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2021-11-15 11:13:01,912] INFO [/config/changes-event-process-thread]:
Shutdown completed
(kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2021-11-15 11:13:01,912] INFO [/config/changes-event-process-thread]:
Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2021-11-15 11:13:01,913] INFO [SocketServer brokerId=1] Stopping socket
server request processors (kafka.network.SocketServer)
[2021-11-15 11:13:01,920] INFO [SocketServer brokerId=1] Stopped socket
server request processors (kafka.network.SocketServer)
[2021-11-15 11:13:01,921] INFO [data-plane Kafka Request Handler on Broker
1], shutting down (kafka.server.KafkaRequestHandlerPool)
[2021-11-15 11:13:01,922] INFO [data-plane Kafka Request Handler on Broker
1], shut down completely (kafka.server.KafkaRequestHandlerPool)
[2021-11-15 11:13:01,927] INFO [ExpirationReaper-1-AlterAcls]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,946] INFO [ExpirationReaper-1-AlterAcls]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,946] INFO [ExpirationReaper-1-AlterAcls]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,947] INFO [KafkaApi-1] Shutdown complete.
(kafka.server.KafkaApis)
[2021-11-15 11:13:01,948] INFO [ExpirationReaper-1-topic]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,995] INFO [ExpirationReaper-1-topic]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,995] INFO [ExpirationReaper-1-topic]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:01,997] INFO [TransactionCoordinator id=1] Shutting down.
(kafka.coordinator.transaction.TransactionCoordinator)
[2021-11-15 11:13:01,998] INFO [ProducerId Manager 1]: Shutdown complete:
last producerId assigned 8000 (kafka.coordinator.transaction.ProducerIdManager)
[2021-11-15 11:13:01,999] INFO [Transaction State Manager 1]: Shutdown
complete (kafka.coordinator.transaction.TransactionStateManager)
[2021-11-15 11:13:01,999] INFO [Transaction Marker Channel Manager 1]:
Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2021-11-15 11:13:01,999] INFO [Transaction Marker Channel Manager 1]:
Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2021-11-15 11:13:01,999] INFO [Transaction Marker Channel Manager 1]:
Shutdown completed
(kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2021-11-15 11:13:02,000] INFO [TransactionCoordinator id=1] Shutdown
complete. (kafka.coordinator.transaction.TransactionCoordinator)
[2021-11-15 11:13:02,000] INFO [GroupCoordinator 1]: Shutting down.
(kafka.coordinator.group.GroupCoordinator)
[2021-11-15 11:13:02,001] INFO [ExpirationReaper-1-Heartbeat]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,176] INFO [ExpirationReaper-1-Heartbeat]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,176] INFO [ExpirationReaper-1-Heartbeat]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,176] INFO [ExpirationReaper-1-Rebalance]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,263] INFO [ExpirationReaper-1-Rebalance]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,263] INFO [ExpirationReaper-1-Rebalance]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,265] INFO [GroupCoordinator 1]: Shutdown complete.
(kafka.coordinator.group.GroupCoordinator)
[2021-11-15 11:13:02,267] INFO [ReplicaManager broker=1] Shutting down
(kafka.server.ReplicaManager)
[2021-11-15 11:13:02,267] INFO [LogDirFailureHandler]: Shutting down
(kafka.server.ReplicaManager$LogDirFailureHandler)
[2021-11-15 11:13:02,268] INFO [LogDirFailureHandler]: Stopped
(kafka.server.ReplicaManager$LogDirFailureHandler)
[2021-11-15 11:13:02,268] INFO [LogDirFailureHandler]: Shutdown completed
(kafka.server.ReplicaManager$LogDirFailureHandler)
[2021-11-15 11:13:02,269] INFO [ReplicaFetcherManager on broker 1] shutting
down (kafka.server.ReplicaFetcherManager)
[2021-11-15 11:13:02,270] INFO [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,270] INFO [ReplicaFetcher replicaId=1, leaderId=3,
fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,274] INFO [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error sending fetch request (sessionId=1317996094, epoch=40216793)
to node 2: (org.apache.kafka.clients.FetchSessionHandler)
java.io.IOException: Client was shutdown before response was read
at
org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:109)
at
kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:110)
at
kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:211)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:301)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:136)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:135)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:118)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
[2021-11-15 11:13:02,274] INFO [ReplicaFetcher replicaId=1, leaderId=3,
fetcherId=0] Error sending fetch request (sessionId=1888531809, epoch=17995123)
to node 3: (org.apache.kafka.clients.FetchSessionHandler)
java.io.IOException: Client was shutdown before response was read
at
org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:109)
at
kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:110)
at
kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:211)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:301)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:136)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:135)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:118)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
[2021-11-15 11:13:02,281] INFO [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,281] INFO [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,282] INFO [ReplicaFetcher replicaId=1, leaderId=3,
fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,291] INFO [ReplicaFetcher replicaId=1, leaderId=3,
fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2021-11-15 11:13:02,303] INFO [ReplicaFetcherManager on broker 1] shutdown
completed (kafka.server.ReplicaFetcherManager)
[2021-11-15 11:13:02,304] INFO [ReplicaAlterLogDirsManager on broker 1]
shutting down (kafka.server.ReplicaAlterLogDirsManager)
[2021-11-15 11:13:02,304] INFO [ReplicaAlterLogDirsManager on broker 1]
shutdown completed (kafka.server.ReplicaAlterLogDirsManager)
[2021-11-15 11:13:02,304] INFO [ExpirationReaper-1-Fetch]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,391] INFO [ExpirationReaper-1-Fetch]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,391] INFO [ExpirationReaper-1-Fetch]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,391] INFO [ExpirationReaper-1-Produce]: Shutting down
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,394] INFO [ExpirationReaper-1-Produce]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,394] INFO [ExpirationReaper-1-Produce]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,394] INFO [ExpirationReaper-1-DeleteRecords]: Shutting
down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,456] INFO [ExpirationReaper-1-DeleteRecords]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,456] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,456] INFO [ExpirationReaper-1-ElectLeader]: Shutting
down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,621] INFO [ExpirationReaper-1-ElectLeader]: Stopped
(kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,621] INFO [ExpirationReaper-1-ElectLeader]: Shutdown
completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-15 11:13:02,642] INFO [ReplicaManager broker=1] Shut down
completely (kafka.server.ReplicaManager)
[2021-11-15 11:13:02,643] INFO [broker-1-to-controller-send-thread]:
Shutting down (kafka.server.BrokerToControllerRequestThread)
[2021-11-15 11:13:02,643] INFO [broker-1-to-controller-send-thread]: Stopped
(kafka.server.BrokerToControllerRequestThread)
[2021-11-15 11:13:02,643] INFO [broker-1-to-controller-send-thread]:
Shutdown completed (kafka.server.BrokerToControllerRequestThread)
[2021-11-15 11:13:02,643] INFO [broker-1-to-controller-send-thread]:
Shutdown completed (kafka.server.BrokerToControllerRequestThread)
[2021-11-15 11:13:02,644] INFO Shutting down. (kafka.log.LogManager)
[2021-11-15 11:13:02,661] INFO [ProducerStateManager
partition=topsense-flink-event-1408268520894107648-reg-0] Writing producer
snapshot at offset 891 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,675] INFO [ProducerStateManager
partition=event-with-wrong-prop-0] Writing producer snapshot at offset 182152
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,678] INFO [ProducerStateManager
partition=normal-event-project-1407297168498364416-0] Writing producer snapshot
at offset 54811 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,679] INFO [ProducerStateManager
partition=normal-event-project-e3ab1f74334149cab19e3f2b5a6150ee-0] Writing
producer snapshot at offset 197081 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,679] INFO [ProducerStateManager
partition=__consumer_offsets-29] Writing producer snapshot at offset 7456
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,680] INFO [ProducerStateManager
partition=normal-event-project-1407297406042771456-0] Writing producer snapshot
at offset 135 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,682] INFO [ProducerStateManager
partition=__consumer_offsets-8] Writing producer snapshot at offset 7693
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,684] INFO [ProducerStateManager
partition=received-data-project-1407296120006250496-0] Writing producer
snapshot at offset 7833494 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,685] INFO [ProducerStateManager
partition=__consumer_offsets-2] Writing producer snapshot at offset 6
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,686] INFO [ProducerStateManager
partition=dongxin_fail_account_reg_retention-0] Writing producer snapshot at
offset 143978 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,687] INFO [ProducerStateManager
partition=abnormal-event-project-1399648264327925760-0] Writing producer
snapshot at offset 1357 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,688] INFO [ProducerStateManager
partition=abnormal-event-project-1410475631933788160-0] Writing producer
snapshot at offset 505 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,691] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1407297406042771456-0] Writing producer
snapshot at offset 16 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,694] INFO [ProducerStateManager
partition=__consumer_offsets-41] Writing producer snapshot at offset 24904
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,698] INFO [ProducerStateManager
partition=dongxin_final_account_pay-0] Writing producer snapshot at offset
16091 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,699] INFO [ProducerStateManager
partition=normal-event-0] Writing producer snapshot at offset 68610353
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,701] INFO [ProducerStateManager
partition=received-data-project-e3ab1f74334149cab19e3f2b5a6150ee-0] Writing
producer snapshot at offset 197130 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,702] INFO [ProducerStateManager
partition=abnormal-event-project-1407296120006250496-0] Writing producer
snapshot at offset 31 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,735] INFO [ProducerStateManager
partition=received-data-project-1399648264327925760-0] Writing producer
snapshot at offset 41145739 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,761] INFO [ProducerStateManager
partition=received-data-project-1410475631933788160-0] Writing producer
snapshot at offset 17264070 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,763] INFO [ProducerStateManager
partition=__consumer_offsets-38] Writing producer snapshot at offset 4979
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,764] INFO [ProducerStateManager
partition=normal-event-project-1407296120006250496-0] Writing producer snapshot
at offset 77015 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,764] INFO [ProducerStateManager
partition=__consumer_offsets-35] Writing producer snapshot at offset 2593
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,765] INFO [ProducerStateManager
partition=__consumer_offsets-26] Writing producer snapshot at offset 6
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,766] INFO [ProducerStateManager
partition=abnormal-event-0] Writing producer snapshot at offset 182349
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,767] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1399648264327925760-0] Writing producer
snapshot at offset 1357 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,769] INFO [ProducerStateManager
partition=dongxin_retry_account_reg_retention-0] Writing producer snapshot at
offset 89036 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,769] INFO [ProducerStateManager
partition=__consumer_offsets-47] Writing producer snapshot at offset 12
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,770] INFO [ProducerStateManager
partition=operation-login-0] Writing producer snapshot at offset 179973
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,786] INFO [ProducerStateManager
partition=original-data-0] Writing producer snapshot at offset 4050
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,834] INFO [ProducerStateManager
partition=normal-event-project-1408268520894107648-0] Writing producer snapshot
at offset 94 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,835] INFO [ProducerStateManager
partition=topsense-flink-event-1408268520894107648-pay-0] Writing producer
snapshot at offset 45 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,842] INFO [ProducerStateManager
partition=original-data-project-e3ab1f74334149cab19e3f2b5a6150ee-0] Writing
producer snapshot at offset 197117 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,843] INFO [ProducerStateManager
partition=topsense-flink-event-1399648264327925760-login-0] Writing producer
snapshot at offset 9457 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,844] INFO [ProducerStateManager
partition=operation-create_role-0] Writing producer snapshot at offset 133
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,846] INFO [ProducerStateManager
partition=__consumer_offsets-23] Writing producer snapshot at offset 2499
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,847] INFO [ProducerStateManager
partition=abnormal-event-project-1408268520894107648-0] Writing producer
snapshot at offset 55 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,848] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1408268520894107648-0] Writing producer
snapshot at offset 55 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,848] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1407297168498364416-0] Writing producer
snapshot at offset 36 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,849] INFO [ProducerStateManager
partition=abnormal-event-project-1407297406042771456-0] Writing producer
snapshot at offset 16 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,849] INFO [ProducerStateManager
partition=topsense-flink-event-1410475631933788160-pay-0] Writing producer
snapshot at offset 38445 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,896] INFO [ProducerStateManager
partition=normal-event-project-1399648264327925760-0] Writing producer snapshot
at offset 161499 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,915] INFO [ProducerStateManager
partition=normal-event-project-1410475631933788160-0] Writing producer snapshot
at offset 75034 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,917] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-e3ab1f74334149cab19e3f2b5a6150ee-0]
Writing producer snapshot at offset 20 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,917] INFO [ProducerStateManager
partition=original-data-project-1bd902d8c3fb4e66ba7bdf70995666c5-0] Writing
producer snapshot at offset 829 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,918] INFO [ProducerStateManager
partition=__consumer_offsets-44] Writing producer snapshot at offset 5205
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,919] INFO [ProducerStateManager
partition=received-data-project-1407297168498364416-0] Writing producer
snapshot at offset 5431387 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,920] INFO [ProducerStateManager
partition=topsense-flink-event-1410475631933788160-reg-0] Writing producer
snapshot at offset 78449 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,922] INFO [ProducerStateManager
partition=__consumer_offsets-5] Writing producer snapshot at offset 2489
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,924] INFO [ProducerStateManager
partition=topsense-flink-event-1410475631933788160-login-0] Writing producer
snapshot at offset 640230 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,925] INFO [ProducerStateManager
partition=__consumer_offsets-32] Writing producer snapshot at offset 3
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,926] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1410475631933788160-0] Writing producer
snapshot at offset 505 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,927] INFO [ProducerStateManager
partition=original-data-project-1407297406042771456-0] Writing producer
snapshot at offset 1248 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,929] INFO [ProducerStateManager
partition=__consumer_offsets-11] Writing producer snapshot at offset 5955
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,929] INFO [ProducerStateManager
partition=__consumer_offsets-20] Writing producer snapshot at offset 2495
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,931] INFO [ProducerStateManager
partition=received-data-project-1bd902d8c3fb4e66ba7bdf70995666c5-0] Writing
producer snapshot at offset 1269 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,931] INFO [ProducerStateManager
partition=topsense-flink-event-1399648264327925760-reg-0] Writing producer
snapshot at offset 5541 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,932] INFO [ProducerStateManager
partition=topsense-exception-0] Writing producer snapshot at offset 78
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,933] INFO [ProducerStateManager
partition=normal-event-project-1bd902d8c3fb4e66ba7bdf70995666c5-0] Writing
producer snapshot at offset 386 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,933] INFO [ProducerStateManager
partition=abnormal-event-project-e3ab1f74334149cab19e3f2b5a6150ee-0] Writing
producer snapshot at offset 20 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,934] INFO [ProducerStateManager
partition=topsense-flink-event-1408268520894107648-login-0] Writing producer
snapshot at offset 3034 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,936] INFO [ProducerStateManager
partition=__consumer_offsets-14] Writing producer snapshot at offset 2492
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,937] INFO [ProducerStateManager
partition=received-data-project-44b7faa09eab496682eae2835c935b43-0] Writing
producer snapshot at offset 175 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,939] INFO [ProducerStateManager
partition=received-data-project-1407297406042771456-0] Writing producer
snapshot at offset 1894 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,939] INFO [ProducerStateManager
partition=abnormal-event-project-1407297168498364416-0] Writing producer
snapshot at offset 36 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,940] INFO [ProducerStateManager
partition=__consumer_offsets-17] Writing producer snapshot at offset 23250
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,941] INFO [ProducerStateManager
partition=event-with-wrong-prop-project-1407296120006250496-0] Writing producer
snapshot at offset 31 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,942] INFO [ProducerStateManager
partition=dwd_dongxin_account_reg-0] Writing producer snapshot at offset 51754
(kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,942] INFO [ProducerStateManager
partition=dongxin_final_account_reg_retention-0] Writing producer snapshot at
offset 559307 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:02,978] INFO [ProducerStateManager
partition=received-data-project-1408268520894107648-0] Writing producer
snapshot at offset 57026 (kafka.log.ProducerStateManager)
[2021-11-15 11:13:03,035] INFO Shutdown complete. (kafka.log.LogManager)
[2021-11-15 11:13:03,056] INFO [feature-zk-node-event-process-thread]:
Shutting down
(kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2021-11-15 11:13:03,056] INFO [feature-zk-node-event-process-thread]:
Stopped
(kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2021-11-15 11:13:03,056] INFO [feature-zk-node-event-process-thread]:
Shutdown completed
(kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2021-11-15 11:13:03,057] INFO [ZooKeeperClient Kafka server] Closing.
(kafka.zookeeper.ZooKeeperClient)
[2021-11-15 11:13:03,169] INFO Session: 0x10005c91c9b0002 closed
(org.apache.zookeeper.ZooKeeper)
[2021-11-15 11:13:03,169] INFO EventThread shut down for session:
0x10005c91c9b0002 (org.apache.zookeeper.ClientCnxn)
[2021-11-15 11:13:03,170] INFO [ZooKeeperClient Kafka server] Closed.
(kafka.zookeeper.ZooKeeperClient)
[2021-11-15 11:13:03,171] INFO [ThrottledChannelReaper-Fetch]: Shutting down
(kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,006] INFO [ThrottledChannelReaper-Fetch]: Stopped
(kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,006] INFO [ThrottledChannelReaper-Fetch]: Shutdown
completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,006] INFO [ThrottledChannelReaper-Produce]: Shutting
down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,227] INFO [ThrottledChannelReaper-Produce]: Stopped
(kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,228] INFO [ThrottledChannelReaper-Produce]: Shutdown
completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,228] INFO [ThrottledChannelReaper-Request]: Shutting
down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,865] INFO [ThrottledChannelReaper-Request]: Stopped
(kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,865] INFO [ThrottledChannelReaper-Request]: Shutdown
completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,865] INFO [ThrottledChannelReaper-ControllerMutation]:
Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,896] INFO [ThrottledChannelReaper-ControllerMutation]:
Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,896] INFO [ThrottledChannelReaper-ControllerMutation]:
Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-15 11:13:04,898] INFO [SocketServer brokerId=1] Shutting down
socket server (kafka.network.SocketServer)
[2021-11-15 11:13:04,924] INFO [SocketServer brokerId=1] Shutdown completed
(kafka.network.SocketServer)
[2021-11-15 11:13:04,925] INFO Metrics scheduler closed
(org.apache.kafka.common.metrics.Metrics)
[2021-11-15 11:13:04,925] INFO Closing reporter
org.apache.kafka.common.metrics.JmxReporter
(org.apache.kafka.common.metrics.Metrics)
[2021-11-15 11:13:04,925] INFO Metrics reporters closed
(org.apache.kafka.common.metrics.Metrics)
[2021-11-15 11:13:04,935] INFO Broker and topic stats closed
(kafka.server.BrokerTopicStats)
[2021-11-15 11:13:04,936] INFO App info kafka.server for 1 unregistered
(org.apache.kafka.common.utils.AppInfoParser)
[2021-11-15 11:13:04,937] INFO [KafkaServer id=1] shut down completed
(kafka.server.KafkaServer)
Ask what reason?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
