[
https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458306#comment-15458306
]
Bill Bejeck commented on KAFKA-3478:
[~mjsax] thanks for the heads up, but it l
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4114:
--
Assignee: Bill Bejeck (was: Guozhang Wang)
> Allow for different "auto.offs
[
https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458985#comment-15458985
]
Bill Bejeck commented on KAFKA-3478:
Makes sense, but I didn't realize tha
[
https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4131:
--
Assignee: Bill Bejeck (was: Guozhang Wang)
> Multiple Regex KStream-Consumers cause N
[
https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467695#comment-15467695
]
Bill Bejeck commented on KAFKA-4131:
If it's ok, I'll pick this one
[
https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4131 started by Bill Bejeck.
--
> Multiple Regex KStream-Consumers cause Null pointer exception in
> addRawR
[
https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4131:
---
Status: Patch Available (was: In Progress)
Working on getting an integration test for this bug fix
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4114 started by Bill Bejeck.
--
> Allow for different "auto.offset.reset" strategies for different
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513498#comment-15513498
]
Bill Bejeck commented on KAFKA-4114:
Hi Matthias,
I've started working on
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531675#comment-15531675
]
Bill Bejeck commented on KAFKA-4114:
No worries on the response.
Thanks
Bill Bejeck created KAFKA-4269:
--
Summary: Multiple KStream instances with at least one Regex source
causes NPE when using multiple consumers
Key: KAFKA-4269
URL: https://issues.apache.org/jira/browse/KAFKA-4269
[
https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4269:
--
Assignee: Bill Bejeck (was: Guozhang Wang)
> Multiple KStream instances with at least
[
https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4269 started by Bill Bejeck.
--
> Multiple KStream instances with at least one Regex source causes NPE when
>
[
https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4269:
---
Description:
I discovered this issue while doing testing for for KAFKA-4114.
KAFKA-4131 fixed the
[
https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4269:
---
Fix Version/s: 0.10.1.0
Status: Patch Available (was: In Progress)
> Multiple KStr
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15563934#comment-15563934
]
Bill Bejeck commented on KAFKA-4114:
I have a working solution, just waiting
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15564050#comment-15564050
]
Bill Bejeck commented on KAFKA-4114:
Fair enough doing so now.
> Allow for di
[
https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4114:
---
Status: Patch Available (was: In Progress)
> Allow for different "auto.offset.reset" s
[
https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-4312:
--
Assignee: Bill Bejeck
> void KTableImpl.writeAsText(String filePath) thr
[
https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4312 started by Bill Bejeck.
--
> void KTableImpl.writeAsText(String filePath) throws NullPointerException w
[
https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4312:
---
Fix Version/s: 0.10.1.1
Status: Patch Available (was: In Progress)
> v
[
https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4312:
---
Component/s: streams
> void KTableImpl.writeAsText(String filePath) throws NullPointerException w
[
https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8878.
Resolution: Fixed
> Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAnd
[
https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8859.
Resolution: Fixed
> Refactor Cache-level Streams Metr
[
https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-6958.
Resolution: Fixed
Thanks again [~fhussonnois] for your hard work and persistence in seeing this
[
https://issues.apache.org/jira/browse/KAFKA-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reopened KAFKA-8807:
Reopening this as I am going to refactor the test to check that close is only
called once during
[
https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-3705.
Resolution: Fixed
> Support non-key joining in KTa
Bill Bejeck created KAFKA-9002:
--
Summary:
org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated
Key: KAFKA-9002
URL: https://issues.apache.org/jira/browse/KAFKA-9002
[
https://issues.apache.org/jira/browse/KAFKA-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8944.
Resolution: Fixed
> Compiler Warning
>
>
> Key
Bill Bejeck created KAFKA-9006:
--
Summary: Flaky Test
KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues
Key: KAFKA-9006
URL: https://issues.apache.org/jira/browse/KAFKA-9006
[
https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reopened KAFKA-8460:
Test failed again in
[https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/25644/testReport/junit
Bill Bejeck created KAFKA-9007:
--
Summary: Flaky Test
kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover
Key: KAFKA-9007
URL: https://issues.apache.org/jira/browse/KAFKA-9007
Project: Kafka
Bill Bejeck created KAFKA-9008:
--
Summary: Flaky Test
kafka.api.SaslSslAdminClientIntegrationTest.testDescribeConfigsForTopic
Key: KAFKA-9008
URL: https://issues.apache.org/jira/browse/KAFKA-9008
Project
Bill Bejeck created KAFKA-9009:
--
Summary: Flaky Test
kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete
Key: KAFKA-9009
URL: https://issues.apache.org/jira/browse/KAFKA-9009
Bill Bejeck created KAFKA-9019:
--
Summary: Flaky Test
kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig
Key: KAFKA-9019
URL: https://issues.apache.org/jira/browse/KAFKA-9019
[
https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9053.
Resolution: Fixed
> AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERS
Bill Bejeck created KAFKA-9072:
--
Summary: Add Section to Streams Developer Guide for Topology
Naming (KIP-307)
Key: KAFKA-9072
URL: https://issues.apache.org/jira/browse/KAFKA-9072
Project: Kafka
Bill Bejeck created KAFKA-9098:
--
Summary: Name Repartition Filter, Source, and Sink Processors
Key: KAFKA-9098
URL: https://issues.apache.org/jira/browse/KAFKA-9098
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8968.
Resolution: Fixed
> Refactor Task-level Metr
[
https://issues.apache.org/jira/browse/KAFKA-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9077.
Resolution: Fixed
> System Test Failure: StreamsSimpleBenchmarkT
[
https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8980.
Resolution: Fixed
> Refactor State-Store-level Metr
[
https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reopened KAFKA-9011:
There's still something left to address on this PR
[https://github.com/apache/kafka/pull
[
https://issues.apache.org/jira/browse/KAFKA-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9072.
Resolution: Fixed
> Add Section to Streams Developer Guide for Topology Naming (KIP-
Bill Bejeck created KAFKA-9181:
--
Summary: Flaky test
kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe
Key: KAFKA-9181
URL: https://issues.apache.org/jira/browse/KAFKA-9181
Bill Bejeck created KAFKA-9182:
--
Summary: Flaky Test
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled
Key: KAFKA-9182
Bill Bejeck created KAFKA-9187:
--
Summary:
kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
Key: KAFKA-9187
URL: https://issues.apache.org/jira/browse/KAFKA-9187
Bill Bejeck created KAFKA-9188:
--
Summary: Flaky Test
SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads
Key: KAFKA-9188
URL: https://issues.apache.org/jira/browse/KAFKA-9188
Bill Bejeck created KAFKA-10404:
---
Summary: Flaky Test
kafka.api.SaslSslConsumerTest.testCoordinatorFailover
Key: KAFKA-10404
URL: https://issues.apache.org/jira/browse/KAFKA-10404
Project: Kafka
Bill Bejeck created KAFKA-10405:
---
Summary: Flaky Test
org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState
Key: KAFKA-10405
URL: https://issues.apache.org/jira/browse/KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9273.
Resolution: Fixed
> Refactor AbstractJoinIntegrationTest and Sub-clas
[
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 ra
[
https://issues.apache.org/jira/browse/KAFKA-16991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-16991.
-
Resolution: Fixed
> Flaky T
Bill Bejeck created KAFKA-17248:
---
Summary: Extend KIP-714 to allow for registering additional
metrics with clients
Key: KAFKA-17248
URL: https://issues.apache.org/jira/browse/KAFKA-17248
Project: Kafka
Bill Bejeck created KAFKA-17561:
---
Summary: New Operator Metrics for Kafka Streams
Key: KAFKA-17561
URL: https://issues.apache.org/jira/browse/KAFKA-17561
Project: Kafka
Issue Type: Improvement
Bill Bejeck created KAFKA-9798:
--
Summary:
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses
Key: KAFKA-9798
URL: https://issues.apache.org/jira/browse/KAFKA-9798
Bill Bejeck created KAFKA-9976:
--
Summary: Aggregates should reuse repartition nodes
Key: KAFKA-9976
URL: https://issues.apache.org/jira/browse/KAFKA-9976
Project: Kafka
Issue Type: Improvement
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
[
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
[
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 Stre
[
https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9086.
Resolution: Fixed
> Refactor Processor Node Streams Metr
Bill Bejeck created KAFKA-9273:
--
Summary: Refactor AbstractJoinIntegrationTest and Sub-classes
Key: KAFKA-9273
URL: https://issues.apache.org/jira/browse/KAFKA-9273
Project: Kafka
Issue Type
Bill Bejeck created KAFKA-9294:
--
Summary: Enhance DSL Naming Guide to Include All Naming Rules
Key: KAFKA-9294
URL: https://issues.apache.org/jira/browse/KAFKA-9294
Project: Kafka
Issue Type
Bill Bejeck created KAFKA-9398:
--
Summary: Kafka Streams main thread may not exit even after close
timeout has passed
Key: KAFKA-9398
URL: https://issues.apache.org/jira/browse/KAFKA-9398
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8821.
Resolution: Fixed
Resolved via [https://github.com/apache/kafka/pull/7969]
> Avoid patt
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7317.
Resolution: Fixed
> Use collections subscription for main consumer to reduce metad
[
https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9152.
Resolution: Fixed
> Improve Sensor Retrieval
> -
>
>
Bill Bejeck created KAFKA-9530:
--
Summary: Flaky Test
kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout
Key: KAFKA-9530
URL: https://issues.apache.org/jira/browse/KAFKA-9530
[
https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9533.
Resolution: Fixed
> ValueTransform forwards `null` val
[
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
[
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 w
[
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-tena
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
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-5226:
--
Assignee: Bill Bejeck (was: Matthias J. Sax)
> NullPointerException (NPE)
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-5226 started by Bill Bejeck.
--
> NullPointerException (NPE) in SourceNodeRecordDeserializer.deserial
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025404#comment-16025404
]
Bill Bejeck commented on KAFKA-5226:
I've been able to reproduce the prob
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5226:
---
Attachment: streamsAppTwo.log
streamsAppThree.log
streamsAppOne.log
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5226:
---
Fix Version/s: 0.11.0.0
> NullPointerException (NPE) in SourceNodeRecordDeserializer.deserial
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5226:
---
Status: Patch Available (was: In Progress)
> NullPointerException (NPE)
[
https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5226:
---
Fix Version/s: (was: 0.11.0.0)
0.11.0.1
> NullPointerException (NPE)
Bill Bejeck created KAFKA-5363:
--
Summary: Add restoreAll functionality to StateRestoreCallback
Key: KAFKA-5363
URL: https://issues.apache.org/jira/browse/KAFKA-5363
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Description: Add a new method {{restoreAll(KeyValue
records)}} to the {{StateRestoreCallback}} to
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Description: Add a new method {{restoreAll(KeyValue
records)}} to the {{StateRestoreCallback}} to
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Description: Add a new method {{restoreAll(List>
records)}} to the {{StateRestoreCallback}} to ena
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Summary: Add ability to batch restore and receive restoration stats. (was:
Add restoreAll
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Description:
Currently, when restoring a state store in a Kafka Streams application, we put
one key
[
https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5363:
---
Description:
Currently, when restoring a state store in a Kafka Streams application, we put
one key
[
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](topicPatt
[
https://issues.apache.org/jira/browse/KAFKA-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-2058:
--
Assignee: Bill Bejeck
> ProducerTest.testSendWithDeadBroker transient fail
[
https://issues.apache.org/jira/browse/KAFKA-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933260#comment-14933260
]
Bill Bejeck commented on KAFKA-2058:
I've been trying to reproduce this erro
Bill Bejeck created KAFKA-2872:
--
Summary: Error starting KafkaStream caused by sink not being
connected to parent source/processor nodes
Key: KAFKA-2872
URL: https://issues.apache.org/jira/browse/KAFKA-2872
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 started by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 started by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 stopped by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2872 stopped by Bill Bejeck.
--
> Error starting KafkaStream caused by sink not being connected to parent
>
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2872:
---
Fix Version/s: 0.9.0.0
Status: Patch Available (was: Open)
Updated the
[
https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15020741#comment-15020741
]
Bill Bejeck commented on KAFKA-2872:
There appears to be a test fai
Bill Bejeck created KAFKA-2902:
--
Summary: StreamingConfig getConsumerConfiigs uses
getRestoreConsumerConfigs instead of getBaseConsumerConfigs
Key: KAFKA-2902
URL: https://issues.apache.org/jira/browse/KAFKA-2902
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2902 started by Bill Bejeck.
--
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2902 stopped by Bill Bejeck.
--
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead
[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
---
Status: Patch Available (was: Open)
Changes made for using getBaseConsumerProps from StreamingConfig
901 - 1000 of 1052 matches
Mail list logo
