Re: [DISCUSSION] KIP-422: Add support for user/client configuration in the Kafka Admin Client

Hi, Yaodong, Thanks for the updated KIP. A few more comments below. 11. For quotas, in addition to user and client, we need to be able to set a quota for combination. Would that be a new resource type? How would the name look like for this resource? 12. Similarly, to support customizable quota

[jira] [Resolved] (KAFKA-8101) Different Processor Node Count on Scala API

[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8101. Resolution: Not A Bug There is a known issue with KGroupedStream#count in the Scala API where there

Re: [VOTE] KIP-415: Incremental Cooperative Rebalancing in Kafka Connect

Excellent work, Konstantine! +1 (binding) On Mon, Mar 11, 2019 at 8:05 PM Konstantine Karantasis < konstant...@confluent.io> wrote: > Thanks Jason! > That makes perfect sense. The change is reflected in the KIP now. > "compatible" will be the default mode for "connect.protocol" > > Cheers, > Kon

[jira] [Created] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

Gregory Koshelev created KAFKA-8104: --- Summary: Consumer cannot rejoin to the group after rebalancing Key: KAFKA-8104 URL: https://issues.apache.org/jira/browse/KAFKA-8104 Project: Kafka Iss

Re: Fluent Kafka Streams Test + Schema Registry Mock

> At the mean time, some of the syntax sugars >> may be a good learning lessons for AK streams test-utils to improve further >> indeed. I agree with this. In retrospective, the current API has some issues because it can lead to ambiguity. For example `ConsumerRecordFactory#create(K key, V value)`

[jira] [Created] (KAFKA-8103) Kafka SIGSEGV on kafka-network-thread

Sean Humbarger created KAFKA-8103: - Summary: Kafka SIGSEGV on kafka-network-thread Key: KAFKA-8103 URL: https://issues.apache.org/jira/browse/KAFKA-8103 Project: Kafka Issue Type: Bug Aff

Re: ​Inconsistent state in Account Debit - Credit Application Using Kafka Transaction

That is not possible. On read, it's not even known which records belong to the same "write transaction". Note, that this is how transactions work in general: assume you have a database and a transactions updates two rows. After the transaction commits, you can read those updates, but you don't kno

​Inconsistent state in Account Debit - Credit Application Using Kafka Transaction

Hi , Please address my issue Account A sends 500 bucks to Account B , We are using a topic Account having multiple partitions to record these events Producer -> Transaction starts Account A BalanceA - 500 to topic Account , partition p0 Account B BalanceB + 500 to topic Account , partition p1

[jira] [Created] (KAFKA-8102) Trogdor - Add Produce workload transaction generator by interval

Stanislav Kozlovski created KAFKA-8102: -- Summary: Trogdor - Add Produce workload transaction generator by interval Key: KAFKA-8102 URL: https://issues.apache.org/jira/browse/KAFKA-8102 Project: K

[jira] [Created] (KAFKA-8101) Optimization Has Different Processor Node Count on Scala API

Bill Bejeck created KAFKA-8101: -- Summary: Optimization Has Different Processor Node Count on Scala API Key: KAFKA-8101 URL: https://issues.apache.org/jira/browse/KAFKA-8101 Project: Kafka Issue

[jira] [Created] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

Shengnan YU created KAFKA-8100: -- Summary: If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log Key: KAFKA-8100 URL: https://issues.apache.org/jira/browse/KAFKA-8100 Pro