[jira] [Created] (KAFKA-7623) SMT STRUCT to MASK or FILTER

Chenchu Lakshman kumar created KAFKA-7623: - Summary: SMT STRUCT to MASK or FILTER Key: KAFKA-7623 URL: https://issues.apache.org/jira/browse/KAFKA-7623 Project: Kafka Issue Type: Test

Re: [DISCUSS] KIP-360: Improve handling of unknown producer

Hello Jason, thanks for the great write-up. 0. One question about the migration plan: "The new GetTransactionState API and the new version of the transaction state message will not be used until the inter-broker version supports it." I'm not so clear about the implementation details here: say a br

[jira] [Resolved] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-4601. Resolution: Fixed Marking this resolved with [https://github.com/apache/kafka/pull/5451.] As [~guo

Re: [DISCUSS] KIP-388 Add observer interface to record request and response

Lincong, Thanks for the KIP. I have a question about the lifecycle of request and response. With the current (requestAdapter, responseAdapter) implementation, the observer can potentially extend the lifecycle of request and response through adapter. Anyone can implement own observer, and some obse

Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id

Hey Boyang, Thanks for the updates. From a high level, I think this actually complements Konstantine's writeup on incremental rebalancing. The gap we're addressing is providing a way to bind the the partition assignment of a group to a set of user-provided ids so that we are not so reliant on the

Jenkins build is back to normal : kafka-trunk-jdk8 #3199

See

Re: [VOTE] KIP-386: Standardize on Min/Avg/Max metrics' default values

Hey everybody, I've finished with the implementation, here is the PR: https://github.com/apache/kafka/pull/5908 On Mon, Nov 12, 2018 at 6:58 PM Stanislav Kozlovski wrote: > Thank you, everybody, for the votes and discussion. The KIP has passed > with 3 binding votes (Harsha, Jun, Dong) and 1 no

Build failed in Jenkins: kafka-trunk-jdk8 #3198

See Changes: [jason] MINOR: Remove unused abstract function in test class (#5888) -- [...truncated 2.40 MB...] org.apache.kafka.connect.transforms.CastTest > castWholeRec

Jenkins build is back to normal : kafka-trunk-jdk11 #94

See

Build failed in Jenkins: kafka-trunk-jdk8 #3197

See Changes: [colin] Trogdor: Fix /coordinator/tasks parameters to accept long values (#5905) [colin] KAFKA-7514: Add threads to ConsumeBenchWorker (#5864) -- [...truncat

Jenkins build is back to normal : kafka-trunk-jdk8 #3196

See

[jira] [Created] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

Di Campo created KAFKA-7622: --- Summary: Add findSessions functionality to ReadOnlySessionStore Key: KAFKA-7622 URL: https://issues.apache.org/jira/browse/KAFKA-7622 Project: Kafka Issue Type: New Fe

[jira] [Created] (KAFKA-7621) Clients can't deal with server IP address change

Bastian Voigt created KAFKA-7621: Summary: Clients can't deal with server IP address change Key: KAFKA-7621 URL: https://issues.apache.org/jira/browse/KAFKA-7621 Project: Kafka Issue Type: Bu

Re: [VOTE] 2.1.0 RC1

+1 (non-binding) Verified signatures and checksums of release artifacts Performed quickstart steps on rc artifacts (both scala 2.11 and 2.12) Andras On Tue, Nov 13, 2018 at 10:51 AM Eno Thereska wrote: > Built code and ran tests. Getting a single integration test failure: > > kafka.log.LogClea

Re: [VOTE] 2.1.0 RC1

Built code and ran tests. Getting a single integration test failure: kafka.log.LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic[3] FAILED java.lang.AssertionError: Contents of the map shouldn't change expected: (340,340), 5 -> (345,345), 10 -> (350,350), 14 -> (

Re: [DISCUSS] KIP-380: Detect outdated control requests and bounced brokers using broker generation

Hi Becket, Dong, Thanks for the discussion. Those are very good points. I think it makes sense to send back STALE_BROKER_EPOCH error to the broker in both cases: 1. Broker gets quickly restarted. In this case, the channel has already been closed during broker shutdown so the broker will not

Build failed in Jenkins: kafka-trunk-jdk8 #3195

See Changes: [github] KAFKA-7612: Fix javac warnings and enable warnings as errors (#5900) [ismael] KAFKA-7605; Retry async commit failures in integration test cases to fix

Build failed in Jenkins: kafka-trunk-jdk11 #93

See Changes: [github] KAFKA-7612: Fix javac warnings and enable warnings as errors (#5900) [ismael] KAFKA-7605; Retry async commit failures in integration test cases to fix -