kafka-consumer-groups.sh with ssl

[Gabriel Machado]

Hi,

I use kafka_2.11-0.10.0.1 with ssl.
I try to see lag between consummers and producers with the
kafka-consumer-groups.sh script.

#bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server
myserver:9092 --list
Error while executing consumer group command Java heap space
java.lang.OutOfMemoryError: Java heap space
    at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
    at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
    at
org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:93)
    at
org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71)
    at
org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154)
    at
org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135)
    at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:323)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:283)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260)
    at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
    at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
    at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
    at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
    at
kafka.admin.AdminClient.kafka$admin$AdminClient$$send(AdminClient.scala:49)
    at
kafka.admin.AdminClient$$anonfun$sendAnyNode$1.apply(AdminClient.scala:61)
    at
kafka.admin.AdminClient$$anonfun$sendAnyNode$1.apply(AdminClient.scala:58)
    at scala.collection.immutable.List.foreach(List.scala:381)
    at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:58)
    at kafka.admin.AdminClient.findAllBrokers(AdminClient.scala:87)
    at kafka.admin.AdminClient.listAllGroups(AdminClient.scala:96)
    at kafka.admin.AdminClient.listAllGroupsFlattened(AdminClient.scala:117)
    at
kafka.admin.AdminClient.listAllConsumerGroupsFlattened(AdminClient.scala:121)
    at
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.list(ConsumerGroupCommand.scala:311)
    at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:63)
    at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)


Can you help me ?

Thanks,
Gabriel.