confluentinc/kafka-rest

View on GitHub

Confluent REST Proxy for Kafka

Stars: 162
Forks: 660
Open beginner issues: 0
Indexed issues: 238
Avg merge: 2d 8h
Merged PRs (30d): 5

Dominant language: Java
License: No license data
Last GitHub push: Sep 8, 2026
Latest indexed: Sep 15, 2026
Contributing guide: No contributing guide
Code of conduct: No code of conduct
Beginner labels: help wanted

Open All

238 open issues indexed

Support setting any consumer configs when creating a new consumer Open

enhancement

confluentinc/kafka-rest#11 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Support multi-topic consumer subscriptions Open

enhancement

confluentinc/kafka-rest#35 · 13 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add regex consumer subscriptions Open

enhancement

confluentinc/kafka-rest#43 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Support Avro schemas as JSON strings or directly embedded JSON Open

enhancement

confluentinc/kafka-rest#45 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Allow per-request override of consumer.request.timeout.ms Open

enhancement

confluentinc/kafka-rest#52 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Avro producer should reuse Avro Schema Parser Open

enhancement

confluentinc/kafka-rest#54 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
configure a rolling file appender in log4j.properties Open

confluentinc/kafka-rest#70 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Avro producer needs tests for more schema types Open

bug

confluentinc/kafka-rest#72 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Allow the consumer to return Avro JSON according to a specifc schema Open

confluentinc/kafka-rest#73 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Invalid produce request missing envelope generates 422 with no error message Open

confluentinc/kafka-rest#85 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
enhancement: implement consumer.request.min.bytes to allow long polling behavior Open

enhancement

confluentinc/kafka-rest#88 · 5 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Remove "format" field from consumer registration Open

confluentinc/kafka-rest#90 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Deadlock in ConsumerWorker in the REST proxy Open

confluentinc/kafka-rest#97 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Schema registry errors (40801) are not documented Open

docs

confluentinc/kafka-rest#100 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Make offset commit support user-specified offsets Open

enhancement

confluentinc/kafka-rest#107 · 10 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Simplify load balancing of kafka-rest with haproxy Open

confluentinc/kafka-rest#110 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Consumer `max_bytes` param does not return any messages if too small Open

confluentinc/kafka-rest#111 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Ability to have separate types for key and value Open

confluentinc/kafka-rest#114 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
AbstractConsumerTest-based tests can fail under load Open

confluentinc/kafka-rest#119 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
How can i get a list of active consumers? Open

enhancement

confluentinc/kafka-rest#131 · 13 comments · 6 reactions · 0 assignees · Indexed Sep 15, 2026
KAFKA REST allows me create a consumer with illegal names but can not delete it Open

confluentinc/kafka-rest#132 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Ability to fetch the latest offset for a topic Open

confluentinc/kafka-rest#139 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Question on retriable error codes Open

confluentinc/kafka-rest#147 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Provide Ability to DELETE consumer groups Open

confluentinc/kafka-rest#148 · 5 comments · 7 reactions · 0 assignees · Indexed Sep 15, 2026
Provide Advertise Port and Listen Port as options Open

enhancement

confluentinc/kafka-rest#149 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
ProducerPool producers are not picking up custom partitioner specified by "partitioner.class" attribute. Open

confluentinc/kafka-rest#150 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Return a different status message when message exceeds max_bytes Open

confluentinc/kafka-rest#170 · 2 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
avro schema with default values Open

confluentinc/kafka-rest#173 · 11 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Consuming with multiple consumer instances giving duplicate messages Open

confluentinc/kafka-rest#175 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Config producer.threads not used in kafka-rest code Open

confluentinc/kafka-rest#181 · 1 comment · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Documentation warning Open

confluentinc/kafka-rest#184 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Bug in ConsumerReadTask.java which causes thread keep pooling kafka until request timeout Open

confluentinc/kafka-rest#186 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Offer SSE(Server Sent Events) for consumers Open

confluentinc/kafka-rest#188 · 1 comment · 6 reactions · 0 assignees · Indexed Sep 15, 2026
the kafka rest not supporting default primitives datatype Open

confluentinc/kafka-rest#194 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Allow number of acks to be specified for producer Open

confluentinc/kafka-rest#195 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add support for new consumer API Open

confluentinc/kafka-rest#204 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
base64 encode binary avro values Open

confluentinc/kafka-rest#207 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Support string keys with Avro values Open

confluentinc/kafka-rest#210 · 33 comments · 27 reactions · 0 assignees · Indexed Sep 15, 2026
Add sanity check for existence of protocol on schema.registry.url Open

confluentinc/kafka-rest#218 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
how can I get global metrics by rest apis? Open

confluentinc/kafka-rest#221 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Kafka proxy messages problem when consuming through fluentd kafka plugin Open

confluentinc/kafka-rest#223 · 9 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Publishing a message to a non-existent topic without auto topic creation returns GATEWAY_TIMEOUT Open

confluentinc/kafka-rest#231 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Use KafkaConsumer 0.9+ for Simple Consumer API Open

confluentinc/kafka-rest#233 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
GetLeaderId do not need to get all partition data of topic Open

confluentinc/kafka-rest#237 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
add an example to cors doc Open

confluentinc/kafka-rest#240 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
upgrade to jetty 9.3 Open

confluentinc/kafka-rest#241 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
We should allow providing 'host.path' or allow for complex paths in 'host.name' Open

confluentinc/kafka-rest#243 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
set confluent long polling properties in kafka-rest programmatically Open

confluentinc/kafka-rest#247 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
kafka-rest properties error Open

confluentinc/kafka-rest#248 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
java.io.IOException: Map failed Open

confluentinc/kafka-rest#260 · 0 comments · 11 reactions · 0 assignees · Indexed Sep 15, 2026

confluentinc/kafka-rest

Get new issues in your inbox