Issues
- 4
Kafka equivalent to HttpRequest's `@RequestScope`
#1017 opened by hrothwell - 1
Listener skipping messages on exceptions when more than one topic subscribed
#1028 opened by henriquelsmti - 2
Kafka Streams and Jackson Serialization results in CodecException when calling Health endpoint
#1026 opened by JacksonFraser - 2
NPE in ConsumerStateBatch.getCurrentRetryCount
#1004 opened by mpkorstanje - 2
Infinite loop in io.micronaut.configuration.kafka.processor.ConsumerState
#995 opened by henriquelsmti - 1
Documentation update for multiple kafka streams
#1022 opened by dradosevic - 0
- 0
Refactor tests to not use KafkaConsumer internals
#982 opened by jeremyg484 - 1
Execute KafkaClient reactive and CompletableFuture methods with TaskExecutors.BLOCKING by default
#956 opened by jeremyg484 - 0
- 1
Retry Mechanism Not Working with Reactive Types in Micronaut Kafka using @KafkaListener
#967 opened by EnriqueWood - 0
Del @Deprecated Kafka
#970 opened by sdelamo - 0
Add ability to conditionally retry messages with KafkaListener's retry error stragegy
#947 opened by MRyanEvans - 5
- 1
- 0
- 0
JMX Metric records-lag incorrect when topic is produced to external to consuming thread
#933 opened by retinaburn - 4
- 0
`@ErrorStrategy` with `@KafkaListener(batch = true)`
#662 opened by awattez - 2
JsonObjectSerde is internal?
#637 opened by henriquelsmti - 6
- 10
Transactional Kafka Producer per thread
#750 opened by pszymczyk - 2
Batch consumer Exception
#676 opened by rnkoaa - 0
NoSuchMethodException: org.apache.kafka.clients.consumer.RangeAssignor.<init>()
#873 opened by ivangfr - 4
Release support to infer kafka key and value deserializer types when batch is enabled
#811 opened by iNviNho - 1
- 0
- 0
- 2
Swallowed exception thrown from custom exception handler -> kafka consumer closed
#705 opened by kziomek - 2
The java.lang.IncompatibleClassChangeError in Micronaut Kafka 4.5.x when running native image (GraalVM 23.0.x)
#713 opened by sbodvanski - 1
- 5
Scraping kafka metrics logs errors
#648 opened by Cybermaxke - 2
ClassCastException (String object cannot be cast to a Number object) in Micrometer while starting up Micronaut 3.8.0 app with Kafka metrics
#671 opened by xiaosongchen1 - 0
- 0
Multi-language documentation for fallback
#817 opened by sdelamo - 1
Not able to get Kafka metrics when enabled
#634 opened by pmmerchant - 1
CI never ends for unit tests with manual test container lifecycle control
#781 opened by guillermocalvo - 1
- 0
- 2
Is it possible to have two different JAAS config configured for two different kafka consumers pointing to two distinct services?
#762 opened by vdharam18 - 3
ClusterAuthorizationException
#752 opened by sabithasekar - 2
Messages not reprocessed by consumer when SerializationException occurs while producing message
#640 opened by larsduelfer - 2
Log exception that caused consumer retry
#642 opened by larsduelfer - 0
Migrate to new configuration ascidoc macro
#652 opened by wetted - 2
Message loss with `ErrorStrategyValue.RETRY_ON_ERROR`
#629 opened by misogl - 1
Exactly-once semantics using kafka transactions only possible using @SendTo in read-process-write-cycle?
#632 opened by larsduelfer - 4
Allow multi-threaded access to KafkaConsumer
#613 opened by Hc747 - 2
Recurring exception in poll-loop when retrying records and when the consumer has left the group
#610 opened by npetryk - 4
Kafka Listener committing whole batch on shutdown
#607 opened by PonzaMatteo - 1