[jira] [Resolved] (KAFKA-15126) Change range queries to accept null lower and upper bounds

[ https://issues.apache.org/jira/browse/KAFKA-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-15126. - Resolution: Fixed [Merged to trunk|https://github.com/apache/kafka/pull/14137] > Change range

[jira] [Updated] (KAFKA-15126) Change range queries to accept null lower and upper bounds

[ https://issues.apache.org/jira/browse/KAFKA-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-15126: Fix Version/s: 3.6.0 > Change range queries to accept null lower and upper bounds >

[jira] [Resolved] (KAFKA-14539) Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map

[ https://issues.apache.org/jira/browse/KAFKA-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-14539. - Resolution: Fixed > Simplify StreamsMetadataState by replacing the Cluster metadata with >

[jira] [Updated] (KAFKA-14539) Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map

[ https://issues.apache.org/jira/browse/KAFKA-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-14539: Fix Version/s: 3.6.0 > Simplify StreamsMetadataState by replacing the Cluster metadata with >

[jira] [Commented] (KAFKA-14609) Kafka Streams Processor API cannot use state stores

[ https://issues.apache.org/jira/browse/KAFKA-14609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656218#comment-17656218 ] Bill Bejeck commented on KAFKA-14609: - It just received approval on the dev list, so I'd say within

[jira] [Resolved] (KAFKA-14609) Kafka Streams Processor API cannot use state stores

[ https://issues.apache.org/jira/browse/KAFKA-14609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-14609. - Resolution: Fixed Fixed by https://issues.apache.org/jira/browse/KAFKA-14388 > Kafka Streams

[jira] [Commented] (KAFKA-14609) Kafka Streams Processor API cannot use state stores

[ https://issues.apache.org/jira/browse/KAFKA-14609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656166#comment-17656166 ] Bill Bejeck commented on KAFKA-14609: - Hi [~philipp94831]  Thanks for reporting this issue.  I

[jira] [Updated] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-14388: Component/s: streams > NPE When Retrieving StateStore with new Processor API >

[jira] [Commented] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635035#comment-17635035 ] Bill Bejeck commented on KAFKA-14388: - Cherry-picked to 3.3 > NPE When Retrieving StateStore with

[jira] [Resolved] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-14388. - Resolution: Fixed Merged PR to trunk > NPE When Retrieving StateStore with new Processor API >

[jira] [Updated] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-14388: Fix Version/s: 3.3.2 > NPE When Retrieving StateStore with new Processor API >

[jira] [Commented] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634526#comment-17634526 ] Bill Bejeck commented on KAFKA-14388: - PR with details of the bug

[jira] [Created] (KAFKA-14388) NPE When Retrieving StateStore with new Processor API

Bill Bejeck created KAFKA-14388: --- Summary: NPE When Retrieving StateStore with new Processor API Key: KAFKA-14388 URL: https://issues.apache.org/jira/browse/KAFKA-14388 Project: Kafka Issue

[jira] [Commented] (KAFKA-12950) Replace EasyMock and PowerMock with Mockito for KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-12950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625246#comment-17625246 ] Bill Bejeck commented on KAFKA-12950: - Merged into trunk > Replace EasyMock and PowerMock with

[jira] [Commented] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514700#comment-17514700 ] Bill Bejeck commented on KAFKA-13739: - [~tiboun] I've assigned the ticket to you and added you as a

[jira] [Assigned] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-13739: --- Assignee: bounkong khamphousone > Sliding window without grace not working >

[jira] [Assigned] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-13739: --- Assignee: (was: Bounkong Khamphousone) > Sliding window without grace not working >

[jira] [Assigned] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-13739: --- Assignee: Bounkong Khamphousone > Sliding window without grace not working >

[jira] [Commented] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499697#comment-17499697 ] Bill Bejeck commented on KAFKA-8659: Merged to trunk, 3.1, and 3.0 branches > SetSchemaMetadata SMT

[jira] [Assigned] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8659: -- Assignee: Marc Löhe > SetSchemaMetadata SMT fails on records with null value and schema >

[jira] [Updated] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8659: --- Fix Version/s: 3.0.1 3.1.1 > SetSchemaMetadata SMT fails on records with null

[jira] [Assigned] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8659: -- Assignee: Bill Bejeck > SetSchemaMetadata SMT fails on records with null value and schema >

[jira] [Assigned] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8659: -- Assignee: (was: Bill Bejeck) > SetSchemaMetadata SMT fails on records with null value and

[jira] [Resolved] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8659. Resolution: Fixed Resovled via https://github.com/apache/kafka/pull/7082 > SetSchemaMetadata SMT

[jira] [Updated] (KAFKA-8659) SetSchemaMetadata SMT fails on records with null value and schema

[ https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8659: --- Fix Version/s: 3.2.0 > SetSchemaMetadata SMT fails on records with null value and schema >

[jira] [Updated] (KAFKA-13507) GlobalProcessor ignores user specified names

[ https://issues.apache.org/jira/browse/KAFKA-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-13507: Affects Version/s: 2.8.0 2.7.0 2.6.0

[jira] [Updated] (KAFKA-13507) GlobalProcessor ignores user specified names

[ https://issues.apache.org/jira/browse/KAFKA-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-13507: Fix Version/s: 3.2.0 > GlobalProcessor ignores user specified names >

[jira] [Updated] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12336: Fix Version/s: 2.8.1 > custom stream naming does not work while calling stream[K,

[jira] [Commented] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368968#comment-17368968 ] Bill Bejeck commented on KAFKA-12336: - cherry-picked to 2.8 > custom stream naming does not work

[jira] [Commented] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368949#comment-17368949 ] Bill Bejeck commented on KAFKA-12336: - merged into trunk > custom stream naming does not work while

[jira] [Updated] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12336: Fix Version/s: 3.0.0 > custom stream naming does not work while calling stream[K,

[jira] [Resolved] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-12336. - Resolution: Fixed > custom stream naming does not work while calling stream[K, V](topicPattern:

[jira] [Updated] (KAFKA-12672) Running test-kraft-server-start results in error

[ https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12672: Affects Version/s: (was: 2.8.0) 3.0.0 > Running

[jira] [Updated] (KAFKA-12672) Running test-kraft-server-start results in error

[ https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12672: Affects Version/s: 2.8.0 > Running test-kraft-server-start results in error >

[jira] [Updated] (KAFKA-12672) Running test-kraft-server-start results in error

[ https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12672: Fix Version/s: 2.8.1 3.0.0 > Running test-kraft-server-start results in error

[jira] [Updated] (KAFKA-12672) Running test-kraft-server-start results in error

[ https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12672: Description: Running the {{test-kraft-server-start}} script in the {{raft}} module results in

[jira] [Updated] (KAFKA-12672) Running test-kraft-server-start results in error

[ https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12672: Description: Running the {{test-kraft-server-start}} script in the {{raft}} module results in

[jira] [Created] (KAFKA-12672) Running test-kraft-server-start results in error

Bill Bejeck created KAFKA-12672: --- Summary: Running test-kraft-server-start results in error Key: KAFKA-12672 URL: https://issues.apache.org/jira/browse/KAFKA-12672 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-3745) Consider adding join key to ValueJoiner interface

[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3745: --- Fix Version/s: 3.0.0 > Consider adding join key to ValueJoiner interface >

[jira] [Resolved] (KAFKA-12393) Document multi-tenancy considerations

[ https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-12393. - Resolution: Fixed Merged to trunk and cherry-picked to 2.8 > Document multi-tenancy

[jira] [Updated] (KAFKA-12393) Document multi-tenancy considerations

[ https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-12393: Fix Version/s: 2.8.0 3.0.0 > Document multi-tenancy considerations >

[jira] [Commented] (KAFKA-3745) Consider adding join key to ValueJoiner interface

[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286622#comment-17286622 ] Bill Bejeck commented on KAFKA-3745: Taking the overloaded method approach with the Scala API causes

[jira] [Comment Edited] (KAFKA-12213) Kafka Streams aggregation Initializer to accept record key

[ https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286114#comment-17286114 ] Bill Bejeck edited comment on KAFKA-12213 at 2/18/21, 5:26 PM: --- Hi,

[jira] [Comment Edited] (KAFKA-12213) Kafka Streams aggregation Initializer to accept record key

[ https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286114#comment-17286114 ] Bill Bejeck edited comment on KAFKA-12213 at 2/18/21, 5:23 PM: --- Hi,

[jira] [Commented] (KAFKA-12213) Kafka Streams aggregation Initializer to accept record key

[ https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286114#comment-17286114 ] Bill Bejeck commented on KAFKA-12213: - Hi, [~MonCalamari]. I have an implementation for the

[jira] [Updated] (KAFKA-8744) Add Support to Scala API for KIP-307 and KIP-479

[ https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8744: --- Fix Version/s: 2.8.0 > Add Support to Scala API for KIP-307 and KIP-479 >

[jira] [Assigned] (KAFKA-3745) Consider adding join key to ValueJoiner interface

[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3745: -- Assignee: Bill Bejeck > Consider adding join key to ValueJoiner interface >

[jira] [Reopened] (KAFKA-10140) Incremental config api excludes plugin config changes

[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-10140: - I resolved this by mistake, reopening now > Incremental config api excludes plugin config changes

[jira] [Updated] (KAFKA-10140) Incremental config api excludes plugin config changes

[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10140: Fix Version/s: (was: 2.7.0) > Incremental config api excludes plugin config changes >

[jira] [Commented] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250330#comment-17250330 ] Bill Bejeck commented on KAFKA-10292: - Since this is an outstanding issue, I'm changing the blocker

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10292: Fix Version/s: 2.8.0 > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10292: Priority: Major (was: Blocker) > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10292: Fix Version/s: (was: 2.7.0) > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Commented] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247511#comment-17247511 ] Bill Bejeck commented on KAFKA-10802: - cherry-picked to 2.7 > Spurious log message when starting

[jira] [Updated] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10802: Fix Version/s: 2.7.0 > Spurious log message when starting consumers >

[jira] [Comment Edited] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247431#comment-17247431 ] Bill Bejeck edited comment on KAFKA-10802 at 12/10/20, 7:07 PM: Thanks

[jira] [Commented] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247431#comment-17247431 ] Bill Bejeck commented on KAFKA-10802: - Thanks for the heads up [~mimaison] I need to do a new RC for

[jira] [Updated] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10772: Fix Version/s: (was: 2.7.0) > java.lang.IllegalStateException: There are insufficient bytes

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245460#comment-17245460 ] Bill Bejeck commented on KAFKA-10772: - Hi [~vvcephei],  Since this appears to be an outstanding

[jira] [Resolved] (KAFKA-10799) AlterIsr path does not update ISR shrink/expand meters

[ https://issues.apache.org/jira/browse/KAFKA-10799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10799. - Resolution: Fixed > AlterIsr path does not update ISR shrink/expand meters >

[jira] [Resolved] (KAFKA-10687) Produce request should be bumped for new error code PRODUCE_FENCED

[ https://issues.apache.org/jira/browse/KAFKA-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10687. - Resolution: Fixed Fixed for 2.7 via https://github.com/apache/kafka/pull/9613 > Produce

[jira] [Assigned] (KAFKA-10679) AK site docs changes need to get ported to Kafka/docs

[ https://issues.apache.org/jira/browse/KAFKA-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-10679: --- Assignee: Bill Bejeck > AK site docs changes need to get ported to Kafka/docs >

[jira] [Issue Comment Deleted] (KAFKA-10679) AK site docs changes need to get ported to Kafka/docs

[ https://issues.apache.org/jira/browse/KAFKA-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10679: Comment: was deleted (was: Current PR https://github.com/apache/kafka/pull/9551) > AK site docs

[jira] [Commented] (KAFKA-10679) AK site docs changes need to get ported to Kafka/docs

[ https://issues.apache.org/jira/browse/KAFKA-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225574#comment-17225574 ] Bill Bejeck commented on KAFKA-10679: - Current PR https://github.com/apache/kafka/pull/9551 > AK

[jira] [Updated] (KAFKA-10679) AK site docs changes need to get ported to Kafka/docs

[ https://issues.apache.org/jira/browse/KAFKA-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10679: Summary: AK site docs changes need to get ported to Kafka/docs (was: AK documentation changes

[jira] [Created] (KAFKA-10679) AK documentation changes need to get ported to Kafka/docs

Bill Bejeck created KAFKA-10679: --- Summary: AK documentation changes need to get ported to Kafka/docs Key: KAFKA-10679 URL: https://issues.apache.org/jira/browse/KAFKA-10679 Project: Kafka

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10370: Fix Version/s: (was: 2.7.0) > WorkerSinkTask: IllegalStateException cased by

[jira] [Updated] (KAFKA-10378) issue when create producer using java

[ https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10378: Fix Version/s: (was: 2.6.1) (was: 2.7.0) > issue when create producer

[jira] [Updated] (KAFKA-9497) Brokers start up even if SASL provider is not loaded and throw NPE when clients connect

[ https://issues.apache.org/jira/browse/KAFKA-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9497: --- Fix Version/s: (was: 2.7.0) > Brokers start up even if SASL provider is not loaded and throw NPE

[jira] [Updated] (KAFKA-10297) Don't use deprecated producer config `retries`

[ https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10297: Fix Version/s: (was: 2.7.0) > Don't use deprecated producer config `retries` >

[jira] [Updated] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10638: Priority: Major (was: Blocker) > QueryableStateIntegrationTest fails due to stricter store

[jira] [Comment Edited] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221610#comment-17221610 ] Bill Bejeck edited comment on KAFKA-10638 at 10/27/20, 5:48 PM: Hey

[jira] [Updated] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10638: Fix Version/s: (was: 2.7.0) 2.7.1 2.8.0 >

[jira] [Commented] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221610#comment-17221610 ] Bill Bejeck commented on KAFKA-10638: - Hey [~vvcephei] I appreciate you wanting to get a fix in for

[jira] [Resolved] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9381. Resolution: Fixed Resolved via [https://github.com/apache/kafka/pull/9486.]   Merged to trunk

[jira] [Updated] (KAFKA-10641) ACL Command hangs with SSL as not existing with proper error code

[ https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10641: Fix Version/s: (was: 2.7.0) 2.8.0 > ACL Command hangs with SSL as not

[jira] [Commented] (KAFKA-10641) ACL Command hangs with SSL as not existing with proper error code

[ https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221052#comment-17221052 ] Bill Bejeck commented on KAFKA-10641: - Hi [~senthilm-ms], since this is not a blocker issue and

[jira] [Updated] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10642: Fix Version/s: (was: 2.7.0) 2.8.0 > Expose the real stack trace if any

[jira] [Commented] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221051#comment-17221051 ] Bill Bejeck commented on KAFKA-10642: - Hi [~senthilm-ms], since this is not a blocker issue and

[jira] [Updated] (KAFKA-10647) Only serialize owned partition when consumer protocol version >= 0

[ https://issues.apache.org/jira/browse/KAFKA-10647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10647: Fix Version/s: 2.7.0 > Only serialize owned partition when consumer protocol version >= 0 >

[jira] [Updated] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10638: Fix Version/s: 2.7.0 > QueryableStateIntegrationTest fails due to stricter store checking >

[jira] [Updated] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9381: --- Priority: Blocker (was: Critical) > Javadocs + Scaladocs not published on maven central >

[jira] [Updated] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9381: --- Fix Version/s: (was: 2.8.0) 2.7.0 > Javadocs + Scaladocs not published on

[jira] [Assigned] (KAFKA-10631) ProducerFencedException is not Handled on Offest Commit

[ https://issues.apache.org/jira/browse/KAFKA-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-10631: --- Assignee: Bruno Cadonna > ProducerFencedException is not Handled on Offest Commit >

[jira] [Updated] (KAFKA-10631) ProducerFencedException is not Handled on Offest Commit

[ https://issues.apache.org/jira/browse/KAFKA-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10631: Fix Version/s: 2.7.0 > ProducerFencedException is not Handled on Offest Commit >

[jira] [Commented] (KAFKA-10554) Perform follower truncation based on epoch offsets returned in Fetch response

[ https://issues.apache.org/jira/browse/KAFKA-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219111#comment-17219111 ] Bill Bejeck commented on KAFKA-10554: - Since this is not a blocker, and we've hit code freeze, I'm

[jira] [Updated] (KAFKA-10554) Perform follower truncation based on epoch offsets returned in Fetch response

[ https://issues.apache.org/jira/browse/KAFKA-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10554: Fix Version/s: (was: 2.7.0) 2.8.0 > Perform follower truncation based on

[jira] [Updated] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-10201: Fix Version/s: (was: 2.7.0) 2.8.0 > Update codebase to use more inclusive

[jira] [Commented] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219093#comment-17219093 ] Bill Bejeck commented on KAFKA-10201: - [~xvrl] , Since we've hit code freeze on 10/21, I'm going to

[jira] [Comment Edited] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218458#comment-17218458 ] Bill Bejeck edited comment on KAFKA-9381 at 10/21/20, 5:59 PM: --- Since this

[jira] [Commented] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218458#comment-17218458 ] Bill Bejeck commented on KAFKA-9381: Since this is a long-standing issue, I'm going to remove the

[jira] [Updated] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9381: --- Priority: Critical (was: Blocker) > Javadocs + Scaladocs not published on maven central >

[jira] [Updated] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9381: --- Fix Version/s: (was: 2.7.0) 2.8.0 > Javadocs + Scaladocs not published on

[jira] [Assigned] (KAFKA-9381) Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-9381: -- Assignee: Bill Bejeck (was: Randall Hauch) > Javadocs + Scaladocs not published on maven

[jira] [Commented] (KAFKA-9910) Implement new transaction timed out error

[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218450#comment-17218450 ] Bill Bejeck commented on KAFKA-9910: This is a sub-task for KIP-588, which is not going in 2.7, so

[jira] [Updated] (KAFKA-9910) Implement new transaction timed out error

[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9910: --- Fix Version/s: (was: 2.7.0) 2.8.0 > Implement new transaction timed out error

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9803: --- Fix Version/s: (was: 2.7.0) 2.8.0 > Allow producers to recover gracefully

[jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218446#comment-17218446 ] Bill Bejeck commented on KAFKA-9803: As discussed with [~bchen225242] offline, looks like KIP-588

[jira] [Comment Edited] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218008#comment-17218008 ] Bill Bejeck edited comment on KAFKA-10515 at 10/20/20, 11:47 PM: -

[jira] [Resolved] (KAFKA-10454) Kafka Streams Stuck in infinite REBALANCING loop when stream <> table join partitions don't match

[ https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10454. - Resolution: Fixed Resolved via https://github.com/apache/kafka/pull/9237 > Kafka Streams Stuck

  1   2   3   4   5   6   7   8   >