Sanvir
Sanvir
I have the same problem, i'm excuting consumer con GKE.
Hi, i had the same problem but now is working fine: Example: ``` from kafka import KafkaConsumer import logging root = logging.getLogger() root.setLevel(logging.INFO) handler = logging.StreamHandler(sys.stdout) handler.setLevel(logging.INFO) formatter = logging.Formatter(...
I can see connections but i can't force delete connections, this is possible??
Sorry, is edge class.
Exist update about this??, just today i start with problems with kafka. ``` ERROR io.confluent.admin.utils.ClusterStatus - Timed out waiting for connection to Zookeeper server ``` I have 3 replicas from...
Yes, this is not a resource problem, i tested remove istio: ``` kubectl label namespace NAMESPACE istio-injection- ``` But if you use istio on your namespace i recommend move kafka...
Me too would like use the plugin with multiples sessions i hope some can help to update the plugin...