clear query| facets| time Search criteria: .   Results from 41 to 50 from 2229 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - [VOTE] KIP-613: Add end-to-end latency metrics to Streams - Kafka - [mail # dev]
...+1 on the updated proposal. Thanks Sophie.On Tue, May 19, 2020 at 11:51 AM John Roesler  wrote:> Thanks for the KIP, Sophie.>> I'm +1 (binding) on the current proposal.>>...
   Author: Guozhang Wang , 2020-05-19, 19:02
[VOTE] KIP-608: Expose Kafka Metrics in Authorizer - Kafka - [mail # dev]
...Zhiguo, thanks for the KIP. +1 from me.GuozhangOn Fri, May 15, 2020 at 2:21 PM Zhiguo Huang wrote:> Thanks to everyone for their input. I've incorporated the changes, and I> think this...
   Author: Guozhang Wang , 2020-05-18, 16:59
[expand - 5 more] - [DISCUSS] KIP-613: Add end-to-end latency metrics to Streams - Kafka - [mail # dev]
...Thanks Sophie, I'm +1 on the updated KIP.On Mon, May 18, 2020 at 8:32 AM Sophie Blee-Goldman wrote:> @Bruno> No, this would be after inserting in the cache/state store/etc -- basically...
   Author: Guozhang Wang , 2020-05-18, 16:32
[KAFKA-10001] Store's own restore listener should be triggered in store changelog reader - Kafka - [issue]
...Streams' state store ``register()`` function passed in `restoreCallback` can potentially also be a `RestoreListener`, in which case its corresponding `onRestoreStart / End / batchRestored` s...    Author: Guozhang Wang , 2020-05-16, 15:27
[KAFKA-8918] Flaky Test org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskCancellation - Kafka - [issue]
...Stacktracejava.lang.AssertionError: Condition not met within timeout 15000. Timed out waiting for expected tasks {"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.ka...    Author: Guozhang Wang , 2020-05-16, 15:25
[KAFKA-5209] Transient failure: kafka.server.MetadataRequestTest.testControllerId - Kafka - [issue]
...Stacktracejava.lang.NullPointerException at kafka.server.MetadataRequestTest.testControllerId(MetadataRequestTest.scala:57) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at ...    Author: Guozhang Wang , 2020-05-16, 15:23
[KAFKA-7042] Fall back to the old behavior when the broker is too old to recognize LIST_OFFSET versions - Kafka - [issue]
...When READ_COMMITTED is turned on (since 0.11.0), LIST_OFFSET requires min_version to be 2 on the consumer client side. On the other hand, if broker is no newer than 0.10.2 it can only recogn...    Author: Guozhang Wang , 2020-05-16, 15:20
[KAFKA-5719] Create a quickstart archetype project for Kafka Streams - Kafka - [issue]
...People have been suggesting to add some tutorial-like web doc sections on how to implement a stream processing application using the Kafka Streams library. Plus the current o.a.k.streams.exa...    Author: Guozhang Wang , 2020-05-16, 15:18
[KAFKA-2045] Memory Management on the consumer - Kafka - [issue]
...We need to add the memory management on the new consumer like we did in the new producer. This would probably include:1. byte buffer re-usage for fetch response partition data.2. byte buffer...    Author: Guozhang Wang , 2020-05-16, 15:15
[KAFKA-3103] Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack - Kafka - [issue]
...Saw this case once:java.lang.AssertionError: Topic metadata is not correctly updated for broker kafka.server.KafkaServer@15414e6f.Expected ISR: List(BrokerEndPoint(0,localhost,41407), Broker...    Author: Guozhang Wang , 2020-05-16, 15:13