[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028260#comment-17028260
]
Boyang Chen commented on KAFKA-8334:
[~windkithk] Thanks for the explanation. I have one thing I
[
https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9475:
--
Assignee: Boyang Chen
> Replace transaction abortion scheduler with a delayed queue
>
[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027784#comment-17027784
]
Boyang Chen commented on KAFKA-8334:
The default heartbeat interval is 3 seconds, and only if you
[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027613#comment-17027613
]
Boyang Chen commented on KAFKA-8334:
Hey [~windkithk], one thing I'm interested is how we configure:
[
https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027577#comment-17027577
]
Boyang Chen commented on KAFKA-9146:
Hey [~feyman] thanks for your interest in contributing! The
[
https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8531:
---
Fix Version/s: (was: 2.5.0)
> Change default replication factor config
>
Boyang Chen created KAFKA-9475:
--
Summary: Replace transaction abortion scheduler with a delayed
queue
Key: KAFKA-9475
URL: https://issues.apache.org/jira/browse/KAFKA-9475
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9447:
--
Assignee: Boyang Chen
> Add examples for EOS standalone and group mode under kafka/examples
>
[
https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023287#comment-17023287
]
Boyang Chen commented on KAFKA-9473:
```
[2020-01-24 07:53:17,594] ERROR [KafkaServer id=1] Fatal
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-8803:
--
Assignee: Sophie Blee-Goldman (was: Boyang Chen)
> Stream will not start due to
[
https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9473:
---
Description:
By running a full set of core system tests, we detected 38/166 test failures
which are
[
https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9473:
---
Description:
By running a full set of core system
Boyang Chen created KAFKA-9473:
--
Summary: A large number of core system tests failing due to Kafka
server failed to start on trunk
Key: KAFKA-9473
URL: https://issues.apache.org/jira/browse/KAFKA-9473
[
https://issues.apache.org/jira/browse/KAFKA-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9466:
---
Description: We shall fill in more details when we actually reach this
stage.
> Add documentation
Boyang Chen created KAFKA-9466:
--
Summary: Add documentation for new stream EOS change
Key: KAFKA-9466
URL: https://issues.apache.org/jira/browse/KAFKA-9466
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9417:
---
Description:
We would like to extend the `TransactionMessageCopier` to use the new
subscription
[
https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9417:
---
Summary: Integration test for new EOS model with vanilla Producer and
Consumer (was: Add extension
[
https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9447:
---
Description:
Although we have integration tests for EOS model, it would be best to also put
them in
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Description:
After 447, one of the big improvement is that we are no longer requiring single
writer
Boyang Chen created KAFKA-9454:
--
Summary: Relax transaction.id security requirement
Key: KAFKA-9454
URL: https://issues.apache.org/jira/browse/KAFKA-9454
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9453:
--
Summary: Make transaction.id optional in group mode EOS
Key: KAFKA-9453
URL: https://issues.apache.org/jira/browse/KAFKA-9453
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-9447:
--
Summary: Add examples for EOS standalone and group mode under
kafka/examples
Key: KAFKA-9447
URL: https://issues.apache.org/jira/browse/KAFKA-9447
Project: Kafka
Boyang Chen created KAFKA-9440:
--
Summary: Add ConsumerGroupCommand to delete static members
Key: KAFKA-9440
URL: https://issues.apache.org/jira/browse/KAFKA-9440
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-9439:
--
Summary: Add more public API tests for KafkaProducer
Key: KAFKA-9439
URL: https://issues.apache.org/jira/browse/KAFKA-9439
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9365.
Resolution: Fixed
> Add consumer group information to txn commit
>
[
https://issues.apache.org/jira/browse/KAFKA-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9365:
---
Description: This effort adds consumer group information to the txn commit
protocol on the broker
[
https://issues.apache.org/jira/browse/KAFKA-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9365:
---
Summary: Add consumer group information to txn commit (was: Add consumer
group information to
[
https://issues.apache.org/jira/browse/KAFKA-9346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9346.
Resolution: Fixed
> Consumer fetch offset back-off with pending transactions
>
[
https://issues.apache.org/jira/browse/KAFKA-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014706#comment-17014706
]
Boyang Chen commented on KAFKA-9421:
At the moment it doesn’t seem necessary for existing use cases.
Boyang Chen created KAFKA-9421:
--
Summary: Restricting access of commit for consumer member
Key: KAFKA-9421
URL: https://issues.apache.org/jira/browse/KAFKA-9421
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-9418:
--
Summary: Add new sendOffsets API to include consumer group metadata
Key: KAFKA-9418
URL: https://issues.apache.org/jira/browse/KAFKA-9418
Project: Kafka
Issue
Boyang Chen created KAFKA-9417:
--
Summary: Add extension to the TransactionsTest.transactions_test
for new EOS model
Key: KAFKA-9417
URL: https://issues.apache.org/jira/browse/KAFKA-9417
Project: Kafka
Boyang Chen created KAFKA-9394:
--
Summary: Add partial success for Consumer offset fetch
Key: KAFKA-9394
URL: https://issues.apache.org/jira/browse/KAFKA-9394
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9377:
---
Description: The current repartition count uses a big while loop to
randomly initialize each
Boyang Chen created KAFKA-9383:
--
Summary: Expose Consumer Group Metadata for Transactional Producer
Key: KAFKA-9383
URL: https://issues.apache.org/jira/browse/KAFKA-9383
Project: Kafka
Issue
Boyang Chen created KAFKA-9378:
--
Summary: Revisit the sub-topology initialization logic
Key: KAFKA-9378
URL: https://issues.apache.org/jira/browse/KAFKA-9378
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9335:
---
Fix Version/s: 2.4.1
> java.lang.IllegalArgumentException: Number of partitions must be at least 1.
Boyang Chen created KAFKA-9377:
--
Summary: Refactor StreamsPartitionAssignor Repartition Count logic
Key: KAFKA-9377
URL: https://issues.apache.org/jira/browse/KAFKA-9377
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9335:
---
Priority: Blocker (was: Major)
> java.lang.IllegalArgumentException: Number of partitions must be
[
https://issues.apache.org/jira/browse/KAFKA-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9365:
--
Assignee: Boyang Chen
> Add consumer group information to producer txn commit
>
Boyang Chen created KAFKA-9365:
--
Summary: Add consumer group information to producer txn commit
Key: KAFKA-9365
URL: https://issues.apache.org/jira/browse/KAFKA-9365
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9346:
--
Assignee: Boyang Chen
> Consumer fetch offset back-off with pending transactions
>
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007853#comment-17007853
]
Boyang Chen commented on KAFKA-9335:
By applying your example, I could successfully reproduce the
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006983#comment-17006983
]
Boyang Chen edited comment on KAFKA-9355 at 1/3/20 5:34 PM:
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007641#comment-17007641
]
Boyang Chen commented on KAFKA-9335:
Sounds good, I will try to reproduce it today.
>
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007101#comment-17007101
]
Boyang Chen commented on KAFKA-9335:
Thanks for the report [~nitay.k]. Could you be more specific
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006986#comment-17006986
]
Boyang Chen commented on KAFKA-9350:
Do we have capability to trace the malicious client in this
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006983#comment-17006983
]
Boyang Chen commented on KAFKA-9355:
Thanks for the report. Does all RocksDB metrics vanish or some
[
https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006972#comment-17006972
]
Boyang Chen commented on KAFKA-9356:
Thanks for the report. For Streams there is only one writer
[
https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006964#comment-17006964
]
Boyang Chen commented on KAFKA-9353:
As the PR only prints the instance id, could you rename the
Boyang Chen created KAFKA-9346:
--
Summary: Consumer fetch offset back-off with pending transactions
Key: KAFKA-9346
URL: https://issues.apache.org/jira/browse/KAFKA-9346
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8587:
---
Description: Currently exactly-once producer is coupled with individual
input partitions. This is
[
https://issues.apache.org/jira/browse/KAFKA-8587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8587:
---
Summary: One producer per thread for Kafka Streams EOS (was: EOS producer
should understand
[
https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990642#comment-16990642
]
Boyang Chen commented on KAFKA-9275:
I don't think adding this information in runtime log will make
[
https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989974#comment-16989974
]
Boyang Chen commented on KAFKA-9274:
Thanks for the summary John. I think what we particularly need
[
https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989904#comment-16989904
]
Boyang Chen commented on KAFKA-9280:
I think the log for consumer is missing. There is no evidence
[
https://issues.apache.org/jira/browse/KAFKA-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989894#comment-16989894
]
Boyang Chen commented on KAFKA-9279:
Hey there, what's the expected behavior in this case? You want
Boyang Chen created KAFKA-9274:
--
Summary: Gracefully handle timeout exceptions on Kafka Streams
Key: KAFKA-9274
URL: https://issues.apache.org/jira/browse/KAFKA-9274
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988991#comment-16988991
]
Boyang Chen commented on KAFKA-9270:
[~vvcephei] In fact timeout exceptions is very common thing, so
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984073#comment-16984073
]
Boyang Chen commented on KAFKA-8803:
To be more specific, quoted from [~hachikuji]:
```
we could
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984069#comment-16984069
]
Boyang Chen commented on KAFKA-8803:
[~rocketraman] Thanks, so the issue happens spontaneously
[
https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983506#comment-16983506
]
Boyang Chen commented on KAFKA-8773:
Hey Raman, wondering whether you got a fix for this issue
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983504#comment-16983504
]
Boyang Chen commented on KAFKA-8803:
[~rocketraman] Hey Raman, I'm currently investigating this
Boyang Chen created KAFKA-9224:
--
Summary: State store should not see uncommitted transaction result
Key: KAFKA-9224
URL: https://issues.apache.org/jira/browse/KAFKA-9224
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9178:
---
Labels: streams (was: )
> Streams changelog topics are not cleaning up during lost task closing
>
Boyang Chen created KAFKA-9178:
--
Summary: Streams changelog topics are not cleaning up during lost
task closing
Key: KAFKA-9178
URL: https://issues.apache.org/jira/browse/KAFKA-9178
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969488#comment-16969488
]
Boyang Chen commented on KAFKA-8803:
You mean [~timvanlaer] transaction coordinator right? Group
[
https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968797#comment-16968797
]
Boyang Chen commented on KAFKA-9148:
If we gave user the option to use either fRocksDB or plain
Boyang Chen created KAFKA-9146:
--
Summary: Add option to force delete members in stream reset tool
Key: KAFKA-9146
URL: https://issues.apache.org/jira/browse/KAFKA-9146
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reopened KAFKA-8972:
> KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback
> state
>
[
https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8677:
---
Priority: Blocker (was: Major)
> Flakey test
>
[
https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9112:
---
Component/s: streams
> Combine streams `onAssignment` with `partitionsAssigned` task creation
>
Boyang Chen created KAFKA-9112:
--
Summary: Combine streams `onAssignment` with `partitionsAssigned`
task creation
Key: KAFKA-9112
URL: https://issues.apache.org/jira/browse/KAFKA-9112
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961544#comment-16961544
]
Boyang Chen commented on KAFKA-8972:
A status update: [~ableegoldman] found the last bug which lies
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959246#comment-16959246
]
Boyang Chen commented on KAFKA-6453:
Executor needs to first check in change into the AK repo, and
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959244#comment-16959244
]
Boyang Chen commented on KAFKA-6453:
Need to have both state store section and DSL section to reflect
Boyang Chen created KAFKA-9090:
--
Summary: LeaveGroup admin request should enforce minimum version
Key: KAFKA-9090
URL: https://issues.apache.org/jira/browse/KAFKA-9090
Project: Kafka
Issue
Boyang Chen created KAFKA-9085:
--
Summary: Admin client should propagate UnsupportedVersion
exception to user instead of crashing
Key: KAFKA-9085
URL: https://issues.apache.org/jira/browse/KAFKA-9085
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957416#comment-16957416
]
Boyang Chen commented on KAFKA-9062:
That's a good suggestion, we should try to utilize as close to
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9075.
Resolution: Not A Problem
> Create FAQ documentation for usage of GlobalKTable vs KTable
>
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956439#comment-16956439
]
Boyang Chen commented on KAFKA-9062:
[~ableegoldman] Could you provide more details on why the
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9075:
---
Description:
We have a KIP which implements global KTable and explains its design reasoning
and
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9075:
---
Labels: newbie newbie++ (was: )
> Create FAQ documentation for usage of GlobalKTable vs KTable
>
Boyang Chen created KAFKA-9075:
--
Summary: Create FAQ documentation for usage of GlobalKTable vs
KTable
Key: KAFKA-9075
URL: https://issues.apache.org/jira/browse/KAFKA-9075
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8728.
Resolution: Cannot Reproduce
> Flaky Test KTableSourceTopicRestartIntegrationTest
>
Boyang Chen created KAFKA-9042:
--
Summary: Auto infer external topic partitions in stream reset tool
Key: KAFKA-9042
URL: https://issues.apache.org/jira/browse/KAFKA-9042
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8973.
Resolution: Won't Fix
> Give user options to turn off linger.ms/batch.size constraint
>
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Priority: Blocker (was: Major)
> Toggle bulkloading hit NPE
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Fix Version/s: 2.4.0
> Toggle bulkloading hit NPE
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Affects Version/s: 2.4.0
> Toggle bulkloading hit NPE
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-8432:
--
Assignee: (was: Boyang Chen)
> Add static membership to Sticky assignor
>
Boyang Chen created KAFKA-8993:
--
Summary: Add an EOS performance test suite similar to
ProducerPerformance
Key: KAFKA-8993
URL: https://issues.apache.org/jira/browse/KAFKA-8993
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Description:
test `test_broker_type_bounce` could sometimes fail due to NPE in changelog
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Summary: Toggle bulkloading hit NPE (was: Reduce
[
https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946232#comment-16946232
]
Boyang Chen commented on KAFKA-8973:
I guess it's not an action item that makes sense, closing it.
>
Boyang Chen created KAFKA-8989:
--
Summary: Embedded broker could not be reached in unit test
Key: KAFKA-8989
URL: https://issues.apache.org/jira/browse/KAFKA-8989
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944806#comment-16944806
]
Boyang Chen commented on KAFKA-8970:
Thanks for the report Nishkam. I suspect your unusual way of
Boyang Chen created KAFKA-8973:
--
Summary: Give user options to turn off linger.ms/batch.size
constraint
Key: KAFKA-8973
URL: https://issues.apache.org/jira/browse/KAFKA-8973
Project: Kafka
Boyang Chen created KAFKA-8972:
--
Summary: Reduce
streams_broker_bounce_test.py#test_broker_type_bounce flakiness
Key: KAFKA-8972
URL: https://issues.apache.org/jira/browse/KAFKA-8972
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8222.
Resolution: Fixed
> Admin client changes to add ability to batch remove static members
>
501 - 600 of 943 matches
Mail list logo
