clear query| facets| time Search criteria: .   Results from 41 to 50 from 24450 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9125] GroupMetadataManager and TransactionStateManager should query the controller instead of zkClient - Kafka - [issue]
...Both classes query their respective topic's partition count via the zkClient. This however could be queried by the broker's local metadata cache....
http://issues.apache.org/jira/browse/KAFKA-9125    Author: Viktor Somogyi-Vass , 2019-11-18, 11:06
[KAFKA-9167] Implement a broker to controller request channel - Kafka - [issue]
...In some cases, we will need to create a new API to replace an operation that was formerly done via ZooKeeper.  One example of this is that when the leader of a partition wants to modify...
http://issues.apache.org/jira/browse/KAFKA-9167    Author: Viktor Somogyi-Vass , 2019-11-18, 11:00
[KAFKA-8958] Fix Kafka Streams JavaDocs with regard to used Serdes - Kafka - [issue]
...In older released, Kafka Streams applied operator specific overwrites of Serdes as in-place overwrites. In newer releases, Kafka Streams tries to re-use Serdes more "aggressively" by pushing...
http://issues.apache.org/jira/browse/KAFKA-8958    Author: Matthias J. Sax , 2019-11-18, 09:26
[expand - 1 more] - Reg : kafka state store HA - Kafka - [mail # user]
...Not exactly sure what your code does. But note, that state stores aresharded and you need to query the right shard (ie, instance).I would recommend to read:https://www.confluent.io/blog/unif...
   Author: Matthias J. Sax , Penumarthi Durga Prasad C... , ... , 2019-11-18, 07:45
[expand - 7 more] - Process for changing producer partition assignment strategy - Kafka - [mail # user]
...Exactly. There is not config to set a global one, hence, you need to setif for each operator that writes into a topic (and for which you want aspecial partitioning). Not sure from the top of...
   Author: Matthias J. Sax , Mikkel Gadegaard , ... , 2019-11-18, 07:37
[KAFKA-9201] Error: Could not find or load main class kafka.Kafka - Kafka - [issue]
...I downloaded kafka2.3.1 on[*https://www-us.apache.org/dist/kafka/2.3.1/kafka-2.3.1-src.tgz*]and edited server.propertiewhen I run this command,it report the error below:[root@kaf...
http://issues.apache.org/jira/browse/KAFKA-9201    Author: wanglei , 2019-11-18, 07:24
[expand - 1 more] - KIP Creation Permission - Kafka - [mail # dev]
...Done.On 11/17/19 1:55 PM, Eric Azama wrote:> Hi,> > I'd like to request permission to create KIPs.> > Wiki ID: eazama> > Thanks,> Eric A.> -----BEGIN PGP SIGNATURE...
   Author: Matthias J. Sax , Eric Azama , ... , 2019-11-18, 07:15
[KAFKA-9202] serde in ConsoleConsumer with access to headers - Kafka - [issue]
...ML thread here : https://lists.apache.org/thread.html/ab8c3094945cb9f9312fd3614a5b4454f24756cfa1a702ef5c739c8f@%3Cusers.kafka.apache.org%3E The Deserializer interface has two methods, one th...
http://issues.apache.org/jira/browse/KAFKA-9202    Author: Jorg Heymans , 2019-11-18, 07:11
[KAFKA-9200] ListOffsetRequest missing error response for v5 - Kafka - [issue]
...It seems ListOffsetResponse getErrorResponse is missing a a case for version 5. I'd have hoped that this kind of case would be picked up by KafkaApisTest.java.lang.IllegalArgumentException: ...
http://issues.apache.org/jira/browse/KAFKA-9200    Author: Lucas Bradstreet , 2019-11-18, 03:23
[KAFKA-9196] Records exposed before advancement of high watermark after segment roll - Kafka - [issue]
...We cache the segment position of the high watermark and last stable offset inside `Log`. There is no logic currently to update the cached position when the segment rolls.Suppose we have a lo...
http://issues.apache.org/jira/browse/KAFKA-9196    Author: Jason Gustafson , 2019-11-17, 22:47