Tried to allocate a collection of size 1667657069, but there are only 16 bytes remaining.

[matheus1lva]

Issue submitter TODO list

• I've looked up my issue in FAQ
• I've searched for an already existing issues here
• I've tried running main-labeled docker image and the issue still persists there
• I'm running a supported version of the application which is listed here

Describe the bug (actual behavior)

	at java.base/java.lang.Thread.run(Thread.java:1583)
2025-07-24 13:59:53,770 ERROR [parallel-14] o.s.b.a.w.r.e.AbstractErrorWebExceptionHandler: [2eb8677b-284]  500 Server Error for HTTP GET "/api/clusters/local/topics/cfmm-events/consumer-groups"
java.lang.RuntimeException: Tried to allocate a collection of size 1667657069, but there are only 16 bytes remaining.
	at org.apache.kafka.common.message.ConsumerProtocolAssignment.read(ConsumerProtocolAssignment.java:107)
	Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
	*__checkpoint ⇢ Handler io.kafbat.ui.controller.ConsumerGroupsController#getTopicConsumerGroups(String, String, ServerWebExchange) [DispatcherHandler]
	*__checkpoint ⇢ io.kafbat.ui.config.CorsGlobalConfiguration$$Lambda/0x0000008001650538 [DefaultWebFilterChain]
	*__checkpoint ⇢ io.kafbat.ui.config.ReadOnlyModeFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ io.kafbat.ui.config.CustomWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ AuthorizationWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ExceptionTranslationWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ LogoutWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ServerRequestCacheWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ReactorContextWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ HttpHeaderWriterWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain]
	*__checkpoint ⇢ HTTP GET "/api/clusters/local/topics/cfmm-events/consumer-groups" [ExceptionHandlingWebHandler]
Original Stack Trace:
		at org.apache.kafka.common.message.ConsumerProtocolAssignment.read(ConsumerProtocolAssignment.java:107)
		at org.apache.kafka.common.message.ConsumerProtocolAssignment.<init>(ConsumerProtocolAssignment.java:75)
		at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:176)
		at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:195)
		at org.apache.kafka.clients.admin.internals.DescribeConsumerGroupsHandler.handledClassicGroupResponse(DescribeConsumerGroupsHandler.java:274)
		at org.apache.kafka.clients.admin.internals.DescribeConsumerGroupsHandler.handleResponse(DescribeConsumerGroupsHandler.java:153)
		at org.apache.kafka.clients.admin.internals.AdminApiDriver.onResponse(AdminApiDriver.java:225)
		at org.apache.kafka.clients.admin.KafkaAdminClient$39.handleResponse(KafkaAdminClient.java:4843)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1397)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1550)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1473)
		at java.base/java.lang.Thread.run(Thread.java:1583)
2025-07-24 13:59:57,902 ERROR [parallel-6] o.s.b.a.w.r.e.AbstractErrorWebExceptionHandler: [2eb8677b-285]  500 Server Error for HTTP GET "/api/clusters/local/topics/cfmm-events/consumer-groups"
java.lang.RuntimeException: Tried to allocate a collection of size 1667657069, but there are only 16 bytes remaining.
	at org.apache.kafka.common.message.ConsumerProtocolAssignment.read(ConsumerProtocolAssignment.java:107)
	Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
	*__checkpoint ⇢ Handler io.kafbat.ui.controller.ConsumerGroupsController#getTopicConsumerGroups(String, String, ServerWebExchange) [DispatcherHandler]
	*__checkpoint ⇢ io.kafbat.ui.config.CorsGlobalConfiguration$$Lambda/0x0000008001650538 [DefaultWebFilterChain]
	*__checkpoint ⇢ io.kafbat.ui.config.ReadOnlyModeFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ io.kafbat.ui.config.CustomWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ AuthorizationWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ExceptionTranslationWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ LogoutWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ServerRequestCacheWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ReactorContextWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ HttpHeaderWriterWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain]
	*__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain]
	*__checkpoint ⇢ HTTP GET "/api/clusters/local/topics/cfmm-events/consumer-groups" [ExceptionHandlingWebHandler]
Original Stack Trace:
		at org.apache.kafka.common.message.ConsumerProtocolAssignment.read(ConsumerProtocolAssignment.java:107)
		at org.apache.kafka.common.message.ConsumerProtocolAssignment.<init>(ConsumerProtocolAssignment.java:75)
		at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:176)
		at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:195)
		at org.apache.kafka.clients.admin.internals.DescribeConsumerGroupsHandler.handledClassicGroupResponse(DescribeConsumerGroupsHandler.java:274)
		at org.apache.kafka.clients.admin.internals.DescribeConsumerGroupsHandler.handleResponse(DescribeConsumerGroupsHandler.java:153)
		at org.apache.kafka.clients.admin.internals.AdminApiDriver.onResponse(AdminApiDriver.java:225)
		at org.apache.kafka.clients.admin.KafkaAdminClient$39.handleResponse(KafkaAdminClient.java:4843)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1397)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1550)
		at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1473)
		at java.base/java.lang.Thread.run(Thread.java:1583)
2025-07-24 14:00:11,839 DEBUG [parallel-14] i.k.u.s.ClustersStatisticsScheduler: Start getting metrics for kafkaCluster: local
2025-07-24 14:00:11,855 DEBUG [parallel-6] i.k.u.s.ClustersStatisticsScheduler: Metrics updated for cluster: local
2025-07-24 14:00:41,837 DEBUG [parallel-11] i.k.u.s.ClustersStatisticsScheduler: Start getting metrics for kafkaCluster: local
2025-07-24 14:00:41,858 DEBUG [parallel-4] i.k.u.s.ClustersStatisticsScheduler: Metrics updated for cluster: local
2025-07-24 14:01:11,839 DEBUG [parallel-5] i.k.u.s.ClustersStatisticsScheduler: Start getting metrics for kafkaCluster: local
2025-07-24 14:01:11,853 DEBUG [parallel-12] i.k.u.s.ClustersStatisticsScheduler: Metrics updated for cluster: local

Empty cluster, with only consumer connected being from https://github.com/platformatic/kafka.

1 topic, 0 messages.

Expected behavior

No response

Your installation details

  kafka:
    image: confluentinc/cp-kafka:latest
    ports:
      - 29092:29092
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_PROCESS_ROLES: broker,controller
      KAFKA_CONTROLLER_QUORUM_VOTERS: 1@kafka:9093
      KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
      KAFKA_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://0.0.0.0:29092,CONTROLLER://kafka:9093
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT,CONTROLLER:PLAINTEXT
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
      KAFKA_AUTO_CREATE_TOPICS_ENABLE: true
      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
      CLUSTER_ID: 4L6g3nShT-eMCtK--X86sw
    volumes:
      - kafka_data:/var/lib/kafka/data

  kafka-ui:
    container_name: kafbat-ui
    image: ghcr.io/kafbat/kafka-ui:latest
    ports:
      - 8080:8080
    environment:
      DYNAMIC_CONFIG_ENABLED: "true"

Steps to reproduce

^ - and have a code connecting to a topic with https://github.com/platformatic/kafka - spin up kafbat-ui and go to consumers

Screenshots

No response

Logs

No response

Additional context

No response

[github-actions]

Hi matheus1lva! 👋

Welcome, and thank you for opening your first issue in the repo!

Please wait for triaging by our maintainers.

As development is carried out in our spare time, you can support us by sponsoring our activities or even funding the development of specific issues.
Sponsorship link

If you plan to raise a PR for this issue, please take a look at our contributing guide.

[Haarolean]

We'd need steps to reproduce this in a form of a minimal, reproducible example. Docker compose file will work, including your custom connector configs.

[kapybro]

Further user feedback is requested. Please reply within 7 days or we might close the issue.

[matheus1lva]

https://github.com/matheus1lva/kafbat-ui

There you have it!

cc @Haarolean

[kapybro]

Thanks for the additional feedback! We'll get back to your issue soon.

[Haarolean]

@matheus1lva thanks for the detailed example!
This seems to be an issue with platformatic/kafka rather than kafka-ui.
Please take a look at this issue: platformatic/kafka#76

v1.9.0 of platformatic/kafka should fix the issue, it seems. Let me know how it goes.