Xiong Ding

@shariffshabir I have the same error. The logic https://github.com/buger/goreplay/blob/master/capture/capture.go#L769 does not work for AWS EKS. I print out all the interfaces returned by `pcap.FindAllDevs()` as blow. None of them is...

@shariffshabir Have you tried below option ``` flag.BoolVar(&Settings.OutputFileConfig.Append, "output-file-append", false, "The flushed chunk is appended to existence file or not. ") ```

It is called `OffsetRequest` in this Python library. https://github.com/dpkp/kafka-python/blob/7ac6c6e29099ccba4d50f5b842972dd7332d0e58/kafka/protocol/offset.py#L93 The API_KEY is 2. https://kafka.apache.org/protocol.html#The_Messages_ListOffsets BTW, I wrote a simple one ``` import kafka class AdminClient(kafka.KafkaAdminClient): def get_earliest_latest_offsets( self, topic_name: str,...

Is there any reason this PR is not merged?

hello, we faced the same issue. Could someone reopen it and fix it?

Any progress?

`transport` does not have the method `shutdown.` The problem here is probably you close event loop without cleanup. Underneath, `transport.close()` closes the underlying socket in the next event loop tick....

Hey, @zs-neo I found an issue after using your patch in production for a few days. The observation is that when a worker process dies, a new worker process is...

Btw, the below minimal program can reproduce what I said. ``` import asyncpg, asyncio async def run(): conn = await asyncpg.connect(host='localhost', port=5432, user='xxx', database='postgres') stmt = await conn.prepare('''SELECT 2 ^...

I have similar issue. `dynamic_startup_nodes = False` works around it for me.