[
https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8147:
--
Assignee: Maarten
> Add changelog topic configuration to KTable suppress
>
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797555#comment-16797555
]
Bill Bejeck commented on KAFKA-7996:
IMHO we should go ahead and add a config for a "client close
[
https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8094.
Resolution: Fixed
> Iterating over cache with get(key) is inefficient
>
[
https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8094:
--
Assignee: Sophie Blee-Goldman
> Iterating over cache with get(key) is inefficient
>
[
https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796140#comment-16796140
]
Bill Bejeck commented on KAFKA-8062:
cherry-picked to 2.2 as well
> StateListener is not notified
[
https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8062.
Resolution: Fixed
> StateListener is not notified when StreamThread dies
>
[
https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8062:
--
Assignee: Guozhang Wang (was: Bill Bejeck)
> StateListener is not notified when StreamThread
[
https://issues.apache.org/jira/browse/KAFKA-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793734#comment-16793734
]
Bill Bejeck edited comment on KAFKA-7027 at 3/15/19 4:08 PM:
-
cherry-picked
[
https://issues.apache.org/jira/browse/KAFKA-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793734#comment-16793734
]
Bill Bejeck commented on KAFKA-7027:
cherry-picked [https://github.com/apache/kafka/pull/6373] tp 2.2
[
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
[
https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8101:
---
Description:
Surfaced from this PR [https://github.com/apache/kafka/pull/6373]
But two topologies
[
https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791984#comment-16791984
]
Bill Bejeck commented on KAFKA-8101:
Update This is actually a bug within our Scala API as the test
[
https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8101:
---
Summary: Different Processor Node Count on Scala API (was: Optimization
Has Different Processor
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
[
https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8062:
--
Assignee: Bill Bejeck
> StateListener is not notified when StreamThread dies
>
[
https://issues.apache.org/jira/browse/KAFKA-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7980.
Resolution: Fixed
Resolving this as the PR build was started before the fix for this test was
[
https://issues.apache.org/jira/browse/KAFKA-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788068#comment-16788068
]
Bill Bejeck commented on KAFKA-7980:
[~rsivaram] sorry about that it didn't occur to me to check the
[
https://issues.apache.org/jira/browse/KAFKA-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8040.
Resolution: Fixed
> Streams needs to retry initTransactions
>
[
https://issues.apache.org/jira/browse/KAFKA-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reopened KAFKA-7980:
Assignee: (was: Rajini Sivaram)
Failed again in build
[
https://issues.apache.org/jira/browse/KAFKA-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8072:
---
Affects Version/s: (was: 2.3.0)
2.2.0
> Transient failure in
>
[
https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8073:
---
Affects Version/s: (was: 2.3.0)
2.2.0
> Transient failure in
[
https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8073:
---
Description:
Failed in build [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/20134/]
[
https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8073:
---
Description:
Failed in build [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/20134/]
Bill Bejeck created KAFKA-8073:
--
Summary: Transient failure in
kafka.api.UserQuotaTest.testThrottledProducerConsumer
Key: KAFKA-8073
URL: https://issues.apache.org/jira/browse/KAFKA-8073
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8072:
---
Labels: flaky-test (was: )
> Transient failure in
>
Bill Bejeck created KAFKA-8072:
--
Summary: Transient failure in
SslSelectorTest.testCloseOldestConnectionWithMultipleStagedReceives
Key: KAFKA-8072
URL: https://issues.apache.org/jira/browse/KAFKA-8072
[
https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786882#comment-16786882
]
Bill Bejeck commented on KAFKA-8062:
Hi [~andrey.v.volkov]
Thanks for reporting this, can you share
[
https://issues.apache.org/jira/browse/KAFKA-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8007:
---
Component/s: streams
> In-memory window store copies on fetch
>
[
https://issues.apache.org/jira/browse/KAFKA-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8007:
---
Fix Version/s: 2.3.0
> In-memory window store copies on fetch
>
[
https://issues.apache.org/jira/browse/KAFKA-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8007:
---
Affects Version/s: 2.3.0
> In-memory window store copies on fetch
>
[
https://issues.apache.org/jira/browse/KAFKA-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7963:
---
Fix Version/s: 2.3.0
> Extract hard-coded Streams metric name strings to centralized place
>
[
https://issues.apache.org/jira/browse/KAFKA-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7963.
Resolution: Fixed
> Extract hard-coded Streams metric name strings to centralized place
>
[
https://issues.apache.org/jira/browse/KAFKA-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7963:
---
Affects Version/s: 2.3.0
> Extract hard-coded Streams metric name strings to centralized place
>
[
https://issues.apache.org/jira/browse/KAFKA-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7963:
--
Assignee: Sophie Blee-Goldman
> Extract hard-coded Streams metric name strings to centralized
Bill Bejeck created KAFKA-8045:
--
Summary: Possible Flaky Test LogOffsetTest.testGetOffsetsBeforeNow
Key: KAFKA-8045
URL: https://issues.apache.org/jira/browse/KAFKA-8045
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7895:
---
Fix Version/s: 2.1.2
> Ktable supress operator emitting more than one record for the same key per
>
[
https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782184#comment-16782184
]
Bill Bejeck commented on KAFKA-7651:
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781755#comment-16781755
]
Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:10 PM:
I've been able to
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781755#comment-16781755
]
Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:09 PM:
I've been able to
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781755#comment-16781755
]
Bill Bejeck commented on KAFKA-8011:
I've been able to verify that both 1.0 and 1.1 tests pass
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8011:
---
Attachment: streams_1_1_tests.png
streams_1_0_test_results.png
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8011:
--
Assignee: Bill Bejeck
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16779472#comment-16779472
]
Bill Bejeck edited comment on KAFKA-8011 at 2/27/19 4:17 PM:
-
Here's the link
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16779472#comment-16779472
]
Bill Bejeck commented on KAFKA-8011:
Here's the link to the build
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8011:
--
Assignee: (was: Bill Bejeck)
> Flaky Test RegexSourceIntegrationTest.
>
[
https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7492:
--
Assignee: Asutosh Pandya
> Explain `null` handling for reduce and aggregate
>
[
https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7492:
---
Affects Version/s: 2.3.0
> Explain `null` handling for reduce and aggregate
>
[
https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7492:
--
Assignee: Bill Bejeck
> Explain `null` handling for reduce and aggregate
>
[
https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7492.
Resolution: Fixed
Thanks asutosh for the contribution!
> Explain `null` handling for reduce and
[
https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7492:
--
Assignee: (was: Bill Bejeck)
> Explain `null` handling for reduce and aggregate
>
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765196#comment-16765196
]
Bill Bejeck commented on KAFKA-7882:
[~nijo]
One other thing to consider the Transform method
[
https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763155#comment-16763155
]
Bill Bejeck edited comment on KAFKA-7905 at 2/7/19 11:07 PM:
-
Hi [~agrrwal],
[
https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763155#comment-16763155
]
Bill Bejeck commented on KAFKA-7905:
Hi [~agrrwal],
I'm still looking into it. Can you share your
[
https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16762871#comment-16762871
]
Bill Bejeck commented on KAFKA-7905:
Hi [~agrrwal]
Thanks for reporting this. What version of
[
https://issues.apache.org/jira/browse/KAFKA-7843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7843:
--
Assignee: Bill Bejeck
> Initializer should have (read) access to key
>
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-7842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7842:
--
Assignee: Bill Bejeck
> Reducer should have (read) access to key
>
[
https://issues.apache.org/jira/browse/KAFKA-7758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16726242#comment-16726242
]
Bill Bejeck commented on KAFKA-7758:
If optimizations are enabled then the above code does work, one
Bill Bejeck created KAFKA-7758:
--
Summary: When Naming a Repartition Topic with Aggregations Reuse
Repartition Graph Node for Multiple Operations
Key: KAFKA-7758
URL: https://issues.apache.org/jira/browse/KAFKA-7758
[
https://issues.apache.org/jira/browse/KAFKA-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7671:
--
Assignee: Bill Bejeck
> A KStream/GlobalKTable join shouldn't reset the repartition flag
>
[
https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7673:
---
Fix Version/s: 2.2.0
> Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize
>
[
https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7673:
---
Issue Type: Improvement (was: Bug)
> Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize
>
[
https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692023#comment-16692023
]
Bill Bejeck commented on KAFKA-7654:
Hi Bruno Bieth,
I understand your point, but by using
[
https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688333#comment-16688333
]
Bill Bejeck commented on KAFKA-7608:
Hi Andy,
The fact that transform, transformValues, and process
[
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
[
https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685508#comment-16685508
]
Bill Bejeck commented on KAFKA-7622:
Hi [~xmar], this seems like a useful feature.
Please note that
[
https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7622:
---
Labels: needs-kip (was: needs-k)
> Add findSessions functionality to ReadOnlySessionStore
>
[
https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7622:
---
Labels: needs-k (was: )
> Add findSessions functionality to ReadOnlySessionStore
>
[
https://issues.apache.org/jira/browse/KAFKA-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1275#comment-1275
]
Bill Bejeck commented on KAFKA-7552:
Done
> StatefulProcessorNode tries to connect state store to
[
https://issues.apache.org/jira/browse/KAFKA-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7552:
---
Fix Version/s: 2.1.0
> StatefulProcessorNode tries to connect state store to processor before it is
[
https://issues.apache.org/jira/browse/KAFKA-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1242#comment-1242
]
Bill Bejeck commented on KAFKA-7552:
Adam thanks for raising the issue.
This situation is fixed with
Bill Bejeck created KAFKA-7534:
--
Summary: Error during CachingKeyValueStore.flush may not allow
RocksDB to close
Key: KAFKA-7534
URL: https://issues.apache.org/jira/browse/KAFKA-7534
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648073#comment-16648073
]
Bill Bejeck commented on KAFKA-7499:
Thanks [~mjsax] I'm a +1 on this ticket
> Extend
[
https://issues.apache.org/jira/browse/KAFKA-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7406:
---
Summary: Naming Join and Grouping Repartition Topics (was: Naming Join and
Grouping Operations)
>
Bill Bejeck created KAFKA-7406:
--
Summary: Naming Join and Grouping Operations
Key: KAFKA-7406
URL: https://issues.apache.org/jira/browse/KAFKA-7406
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7271:
--
Assignee: Bill Bejeck (was: John Roesler)
> Fix ignored test in streams_upgrade_test.py:
[
https://issues.apache.org/jira/browse/KAFKA-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7270:
--
Assignee: Bill Bejeck (was: John Roesler)
> Add latest releases to streams_upgrade_test.py
>
[
https://issues.apache.org/jira/browse/KAFKA-7272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-7272:
--
Assignee: Bill Bejeck (was: John Roesler)
> Fix ignored test in streams_upgrade_test.py:
[
https://issues.apache.org/jira/browse/KAFKA-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7221.
Resolution: Fixed
Duplicated by KAFKA-7027
> Add Build method to StreamsBuilder accepting
Bill Bejeck created KAFKA-7221:
--
Summary: Add Build method to StreamsBuilder accepting Properties
Key: KAFKA-7221
URL: https://issues.apache.org/jira/browse/KAFKA-7221
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4969:
---
Description:
Currently, {{StreamPartitionsAssigner}} does not distinguish different "types"
of
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4969:
---
Description:
Currently, {{StreamPartitionsAssigner}} does not distinguish different "types"
of
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-4969:
---
Description:
Currently, {{StreamPartitionsAssigner}} does not distinguish different "types"
of
Bill Bejeck created KAFKA-7201:
--
Summary: Optimize repartition operations
Key: KAFKA-7201
URL: https://issues.apache.org/jira/browse/KAFKA-7201
Project: Kafka
Issue Type: Improvement
Bill Bejeck created KAFKA-7200:
--
Summary: Preserve serdes used
Key: KAFKA-7200
URL: https://issues.apache.org/jira/browse/KAFKA-7200
Project: Kafka
Issue Type: Improvement
Bill Bejeck created KAFKA-7190:
--
Summary: Under low traffic conditions purging repartition topics
cause WARN statements about UNKNOWN_PRODUCER_ID
Key: KAFKA-7190
URL:
[
https://issues.apache.org/jira/browse/KAFKA-7108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525648#comment-16525648
]
Bill Bejeck commented on KAFKA-7108:
Off the top of my head, I'm also not in favor of extending the
[
https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523853#comment-16523853
]
Bill Bejeck commented on KAFKA-6964:
[~jadireddi] I was thinking along the lines of printing the
[
https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515988#comment-16515988
]
Bill Bejeck edited comment on KAFKA-7035 at 6/18/18 4:35 PM:
-
[~akonopko] can
[
https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515988#comment-16515988
]
Bill Bejeck commented on KAFKA-7035:
[~akonopko] can you share your code so we can diagnose further
[
https://issues.apache.org/jira/browse/KAFKA-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7027:
---
Description:
Add overloaded method to {{StreamsBuilder}} accepting a
{{java.utils.Properties}}
Bill Bejeck created KAFKA-7027:
--
Summary: Overloaded StreamsBuilder Build Method to Accept
java.util.Properties
Key: KAFKA-7027
URL: https://issues.apache.org/jira/browse/KAFKA-7027
Project: Kafka
Bill Bejeck created KAFKA-6964:
--
Summary: Add ability to print all internal topic names
Key: KAFKA-6964
URL: https://issues.apache.org/jira/browse/KAFKA-6964
Project: Kafka
Issue Type: New
Bill Bejeck created KAFKA-6935:
--
Summary: KIP-295 Add Streams Config for Optional Optimization
Key: KAFKA-6935
URL: https://issues.apache.org/jira/browse/KAFKA-6935
Project: Kafka
Issue Type:
Bill Bejeck created KAFKA-6874:
--
Summary: Add Configuration Allowing for Optional Topology
Optimization
Key: KAFKA-6874
URL: https://issues.apache.org/jira/browse/KAFKA-6874
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460262#comment-16460262
]
Bill Bejeck commented on KAFKA-6844:
https://github.com/apache/kafka/pull/4950
> Race condition
[
https://issues.apache.org/jira/browse/KAFKA-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-6844:
---
Description:
There can be a race condition where shut down is called on a StreamThread then
shut
Bill Bejeck created KAFKA-6844:
--
Summary: Race condition between StreamThread and
GlobalStreamThread stopping
Key: KAFKA-6844
URL: https://issues.apache.org/jira/browse/KAFKA-6844
Project: Kafka
Bill Bejeck created KAFKA-6829:
--
Summary: Consumer should retry when encountering unknown topic or
partition error
Key: KAFKA-6829
URL: https://issues.apache.org/jira/browse/KAFKA-6829
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-6509:
---
Labels: newbie (was: )
> Add additional tests for validating store restoration completes before
>
601 - 700 of 766 matches
Mail list logo
