Build failed in Jenkins: kafka-1.1-jdk8 #288

See Changes: [konstantine] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- [...truncated 211.32 KB...] kafka.api.SaslMultiMechanismConsumerTest >

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

See Changes: [github] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- [...truncated 2.95 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Build failed in Jenkins: kafka-2.0-jdk8 #316

See Changes: [konstantine] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- [...truncated 893.53 KB...] kafka.log.LogCleanerTest >

Build failed in Jenkins: kafka-2.5-jdk8 #81

See Changes: [konstantine] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- [...truncated 2.91 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Build failed in Jenkins: kafka-2.1-jdk8 #261

See Changes: [konstantine] MINOR: Fix error message in exception when records have schemas in -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node

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

See Changes: [github] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- [...truncated 2.97 MB...]

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

See Changes: [github] MINOR: Add missing @Override annotation and simplify Thread declarations -- [...truncated 5.96 MB...]

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

See Changes: [github] MINOR: Add missing @Override annotation and simplify Thread declarations -- [...truncated 2.97 MB...]

Build failed in Jenkins: kafka-2.1-jdk8 #260

See Changes: [konstantine] MINOR: Fix code example reference to SchemaBuilder call in Connect's -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node

[jira] [Created] (KAFKA-9784) Add OffsetFetch to the concurrent coordinator test

Boyang Chen created KAFKA-9784: -- Summary: Add OffsetFetch to the concurrent coordinator test Key: KAFKA-9784 URL: https://issues.apache.org/jira/browse/KAFKA-9784 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-9600; EndTxn should enforce strict epoch checking if from client -- [...truncated 5.96 MB...]

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

See Changes: [github] KAFKA-9600; EndTxn should enforce strict epoch checking if from client -- [...truncated 2.97 MB...]

[jira] [Resolved] (KAFKA-9600) EndTxn handler should check strict epoch equality

[ https://issues.apache.org/jira/browse/KAFKA-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9600. Fix Version/s: 2.6.0 Resolution: Fixed > EndTxn handler should check strict epoch

Re: 回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Hey Feyman, thanks for the update. I assume we would rely entirely on the internal changes for `removeMemberFromGroup` by sending a DescribeGroup request first. With that in mind, I don't think we need to add member.id to MemberToRemove anymore, as it is only facing public where users will only

[jira] [Created] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

Matthias J. Sax created KAFKA-9783: -- Summary: Flaky Test QueryableStateIntegrationTest#concurrentAccesses Key: KAFKA-9783 URL: https://issues.apache.org/jira/browse/KAFKA-9783 Project: Kafka

About the time zone set by the consumer group offset

hello apache : I encountered a time zone issue when using consumer group to reset the offset command: ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group g1 --reset-offsets --topic test --to-datetime 2020-03-28T17:00:00.000 --execute Actual time

[jira] [Created] (KAFKA-9782) Kafka Connect InsertField transform - Add the ability to insert event's Key into Value

Ryan Tomczik created KAFKA-9782: --- Summary: Kafka Connect InsertField transform - Add the ability to insert event's Key into Value Key: KAFKA-9782 URL: https://issues.apache.org/jira/browse/KAFKA-9782

[jira] [Created] (KAFKA-9781) TimestampConverter / Allow to specify a time zone when converting unix epoch to string

Al created KAFKA-9781: - Summary: TimestampConverter / Allow to specify a time zone when converting unix epoch to string Key: KAFKA-9781 URL: https://issues.apache.org/jira/browse/KAFKA-9781 Project: Kafka

Re: [VOTE] KIP-447: Producer scalability for exactly once semantics

I agree with Guozhang that the issue only arises for the `read-process-write` pattern and thus we should guard at the read level already and thus auto-downgrading the write path commitTx request seems fine. Note that for producer-only and consumer-only apps the auto-downgrade is totally fine (and

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

See