shotover/shotover-proxy

kafka python driver creates warnings and errors in shotover

Opened this issue · 0 comments

When python producer terminates it generates this log in shotover (for whichever node it was connected to at the time i think:

 17 03:51:10 i495b4929 shotover-proxy[147000]: 2024-04-17T03:51:10.530285Z ERROR shotover::server: connection was unexpectedly terminated
Apr 17 03:51:10 i495b4929 shotover-proxy[147000]: Caused by:
Apr 17 03:51:10 i495b4929 shotover-proxy[147000]:     0: Chain failed to send and/or receive messages, the connection will now be closed.
Apr 17 03:51:10 i495b4929 shotover-proxy[147000]:     1: KafkaSinkCluster transform failed
Apr 17 03:51:10 i495b4929 shotover-proxy[147000]:     2: Invalid metadata, controller points at unknown node BrokerId(-1)

While the consumer is connected it generates this warning fairly regularly in the shotover node it's connected to:

Apr 17 03:56:02 i495b4929 shotover-proxy[147000]: 2024-04-17T03:56:02.185301Z  WARN shotover::server: failed to receive message on tcp stream: Os { code: 104, kind: ConnectionReset, message: "Connection reset by peer" }
Apr 17 03:56:13 i495b4929 shotover-proxy[147000]: 2024-04-17T03:56:13.488846Z  WARN shotover::server: failed to receive message on tcp stream: Os { code: 104, kind: ConnectionReset, message: "Connection reset by peer" }
Apr 17 03:56:19 i495b4929 shotover-proxy[147000]: 2024-04-17T03:56:19.544770Z  WARN shotover::server: failed to receive message on tcp stream: Os { code: 104, kind: ConnectionReset, message: "Connection reset by peer" }
Apr 17 03:56:20 i495b4929 shotover-proxy[147000]: 2024-04-17T03:56:20.200930Z  WARN shotover::server: failed to receive message on tcp stream: Os { code: 104, kind: ConnectionReset, message: "Connection reset by peer" }
Apr 17 03:56:46 i495b4929 shotover-proxy[147000]: 2024-04-17T03:56:46.339697Z  WARN shotover::server: failed to receive message on tcp stream: Os { code: 104, kind: ConnectionReset, message: "Connection reset by peer" }

the messages do get published and are able to be consumed though from what i can see