clear query| facets| time Search criteria: .   Results from 71 to 80 from 74630 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-3816] Provide more context in Kafka Connect log messages using MDC - Kafka - [issue]
...Currently it is relatively difficult to correlate individual log messages with the various threads and activities that are going on within a Kafka Connect worker, let along a cluster of work...    Author: Randall Hauch , 2018-10-10, 14:58
[KAFKA-7243] Add unit integration tests to validate metrics in Kafka Streams - Kafka - [issue]
...We should add an integration test for Kafka Streams, that validates:1. After streams application are started, all metrics from different levels (thread, task, processor, store, cache) are co...    Author: Guozhang Wang , 2018-10-10, 14:57
[KAFKA-7492] Explain `null` handling for reduce and aggregate - Kafka - [issue]
...We currently don't explain how records with `null` value are handled in reduce and aggregate. In particular, what happens when the users' aggregation/reduce `apply()` implementation returns ...    Author: Matthias J. Sax , 2018-10-10, 14:51
[KAFKA-7307] Upgrade EasyMock for Java 11 support - Kafka - [issue]
...A new version of EasyMock and ASM7_EXPERIMENTAL (or ASM7 when Java 11 ships) enabled: shades its dependencies so they can't be upgrad...    Author: Ismael Juma , 2018-10-10, 14:15
[KAFKA-7420] Global stores should be guarded as read-only for regular tasks - Kafka - [issue]
...Global stores should only be update by the global thread. Any other task, should only read from a global store. However, when getting a reference to a global store, all tasks have full read/...    Author: Matthias J. Sax , 2018-10-10, 13:53
[KAFKA-5716] Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - Kafka - [issue]
...Not looking at the very latest code, so the "problem" may have been corrected recently. If so, I apologize. I found the "problem" by code-inspection alone, so I may be wrong. Have not had th...    Author: Per Steffensen , 2018-10-10, 13:53
[expand - 7 more] - [DISCUSS] KIP-378: Enable Dependency Injection for Kafka Streams handlers - Kafka - [mail # dev]
...Hi Wladimir,Of the two approaches in the KIP - i feel the second approach is cleaner.However, am i correct in assuming that you want to have the`ConfiguredStreamsFactory` as a ctor arg in `S...
   Author: Damian Guy , Guozhang Wang , ... , 2018-10-10, 13:52
[DISCUSS] KIP-381 Connect: Tell about records that had their offsets flushed in callback - Kafka - [mail # dev]
...Please help make the proposed changes in KIP-381 become reality. Please comment.KIP:
   Author: Per Steffensen , 2018-10-10, 13:50
java.lang.OutOfMemoryError: Requested array size exceeds VM limit - Kafka - [mail # user]
...Kafka community,Getting *java.lang.OutOfMemoryError: Requested array size exceeds VM **limit,*  when Atlas hook in Hive tries to send Kafka message.Let me know if any workaround possibl...
   Author: Nixon Rodrigues , 2018-10-10, 13:37
[KAFKA-7114] Kafka Not sending few partitions messages to consumers - Kafka - [issue]
...Infrastructure:Kafka is running in cluster mode with 3 brokers and 3 zookeeper instances.Kafka broker is running in t2.xlarge AWS instance.3 Zookeeper instances is running in single t2.xlarg...    Author: Gnanasoundari , 2018-10-10, 12:28