clear query| facets| time Search criteria: .   Results from 1 to 10 from 74847 (0.0s).
Loading phrases to help you
refine your search...
When Kafka stores group information in zookeeper? - Kafka - [mail # user]
...Hi, Kafka users:I tried to gain the information of topic-consumer groups using kafka-consumer-groups.sh. And I found commands below receive different infos:./kafka-consumer-groups.sh --list ...
   Author: 赖剑清 , 2018-10-23, 02:49
[KAFKA-7481] Consider options for safer upgrade of offset commit value schema - Kafka - [issue]
...KIP-211 and KIP-320 add new versions of the offset commit value schema. The use of the new schema version is controlled by the `inter.broker.protocol.version` configuration.  Once the n...
http://issues.apache.org/jira/browse/KAFKA-7481    Author: Jason Gustafson , 2018-10-23, 01:55
[KAFKA-7299] batch LeaderAndIsr requests during auto preferred leader election - Kafka - [issue]
...Currently, in KafkaController.checkAndTriggerAutoLeaderRebalance(), we call onPreferredReplicaElection() one partition at a time. This means that the controller will be sending LeaderAndIsrR...
http://issues.apache.org/jira/browse/KAFKA-7299    Author: Jun Rao , 2018-10-23, 01:51
[expand - 8 more] - [DISCUSS] KIP-377: TopicCommand to use AdminClient - Kafka - [mail # dev]
...Hi Viktor,+1 to this KIP.I would very much like to see AdminClient in TopicCommand. This would alsoallow us to efficiently implement new features like the "--under-min-isr"option I proposed ...
   Author: Kevin Lu , Colin McCabe , ... , 2018-10-23, 01:33
[expand - 3 more] - [DISCUSS] KIP-351: Add --under-min-isr option to describe topics command - Kafka - [mail # dev]
...Hi Mickael,Thanks for the suggestion for getting the "computed" configuration fromAdminClient.describeConfigs(). That's exactly what I was looking for!I have updated the KIP to use AdminClie...
   Author: Kevin Lu , Mickael Maison , ... , 2018-10-23, 01:33
[expand - 3 more] - AVRO Schema with optional field ("type": "record") - Kafka - [mail # user]
...The idl2schemata tool in avro-tools can help:[user@host]$ cat test.idlprotocol EmployeeProtocol{  record Employee {    string name;    long employeeId;  } ...
   Author: Jacob Sheck , Mina Aslani , ... , 2018-10-23, 01:25
[KAFKA-7236] Add --under-min-isr option to describe topics command - Kafka - [issue]
...The "min.insync.replicas" configuration specifies the minimum number of insync replicas required for a partition to accept messages from the producer. If the insync replica count of a partit...
http://issues.apache.org/jira/browse/KAFKA-7236    Author: Kevin Lu , 2018-10-23, 00:41
[expand - 9 more] - [DISCUSS] KIP-380: Detect outdated control requests and bounced brokers using broker generation - Kafka - [mail # dev]
...Hi, Patrick,Yes, that's the general sequence. After step 2, the shutting down brokercan give up the controlled shutdown process and proceed to shut down. Whenit's restarted, it could still r...
   Author: Jun Rao , Patrick Huang , ... , 2018-10-23, 00:32
[KAFKA-7510] KStreams RecordCollectorImpl leaks data to logs on error - Kafka - [issue]
...org.apache.kafka.streams.processor.internals.RecordCollectorImpl leaks data on error as it dumps the value / message payload to the logs.This is problematic as it may contain personally iden...
http://issues.apache.org/jira/browse/KAFKA-7510    Author: Mr Kafka , 2018-10-23, 00:02
[KAFKA-7530] Need to allow overwrite ssl.endpoint.identification.algorithm.config - Kafka - [issue]
...We are in the process of upgrading our system to use Confluent 5.0.0 (which is using Kafka 2.0.0). I found out SslConfigs ( clients/src/main/java/org/apache/kafka/common/config/SslConfigs.ja...
http://issues.apache.org/jira/browse/KAFKA-7530    Author: Sophie Qian , 2018-10-22, 23:41