HI all, Using AKKA 2.3.12 and experimental version of AKKA persistence w/ KAFKA plugin (Plan to upgrade to prod version soon, just cannot do it immediately)
I am using the KAFKA persistence plugin and see 2 kinds of errors mainly a. First is with reference to issue - https://github.com/akka/akka/issues/17955. b. kafka offset out of range exception. The first one happened randomly and even if i restart the error continues. The second one is generally when I kill one of the nodes in cluster forcefully . Basically I am using the clustersharding pattern where i have 4 persisters in my cluster of 2 nodes, each writing to a specific topic in Kafka. Help needed a. I am not sure how to clean up the coordinator shard data in KAFKA - Any pointers here (any kafka commands specically, which topic , also do i need to restart the AKKA cluster) b. I am not sure why this error comes up frequently just on failover. Is this fixed in later version. (Pushing messages at very low rate) Am keen on using the sharding pattern to increase throughput. Just stuck here w/ these 2 errors. Any suggestions appreciated. Thanks -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
