MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-692230839
oh @mjsax as far as the workaround we call `remove` before `add`, that
solved the memory issue and for the most part solved the
ConcurrentModificationException since less time
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691360304
@mjsax that sounds like it will work for the majority of the use cases I've
come across. One thing thats not clear to me is how kstream operations that are
down stream of a
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
@mjsax its been a while since I looked at the code but from what I remember
from looking through the commit history it used to throw exceptions and there
was a commit thats
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-690582299
I use the DSL almost exclusively so the KIP is written up from that
perspective but I agree the problem is with punctuate.
