chia7712 commented on pull request #8659:
URL: https://github.com/apache/kafka/pull/8659#issuecomment-629044613
@guozhangwang @showuon Could you take a look? thanks!
This is an automated message from the Apache Git Service.
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r425577307
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java
##
@@ -114,7 +105,7 @@ public void
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r425577094
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java
##
@@ -1,71 +0,0 @@
-/*
- * Licensed to the
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r425576674
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -113,10 +113,12 @@ public void
jiameixie commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-629033628
@cmccabe I updated it to openjdk:11. Is that ok?
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8311.
Resolution: Duplicate
Closing this ticket – KIP-572 / KAFKA-9274 does subsume it.
>
jiameixie commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-629031848
@OneCricketeer So if update to OpenJDK 11, there is no need to set
default_jdk according to machine architecture. Thanks for your reminding
jiameixie commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-629030715
@OneCricketeer Openjdk:11 is multi-arch, and openjdk:8 is not multi-arch.
It's ok to run command "docker run -it openjdk:11 bash" on both arm and x86,
while running command
jiameixie commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-629027425
@OneCricketeer I tested just now. Openjdk:11 is a multi-arch. X86 and arm
use the same image name.
This is
[
https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107921#comment-17107921
]
Matthias J. Sax commented on KAFKA-7912:
Can you dig out the ticket or PR? And than close this
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107917#comment-17107917
]
Matthias J. Sax commented on KAFKA-6520:
This is a quite tricky one... You can of course try.
OneCricketeer commented on a change in pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#discussion_r425549885
##
File path: tests/docker/ducker-ak
##
@@ -42,7 +42,14 @@ docker_run_memory_limit="2000m"
default_num_nodes=14
# The default OpenJDK base image.
OneCricketeer commented on a change in pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#discussion_r425550291
##
File path: tests/docker/ducker-ak
##
@@ -42,7 +42,14 @@ docker_run_memory_limit="2000m"
default_num_nodes=14
# The default OpenJDK base image.
guozhangwang commented on a change in pull request #8661:
URL: https://github.com/apache/kafka/pull/8661#discussion_r425549980
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -248,17 +243,6 @@ void
[
https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107901#comment-17107901
]
Guozhang Wang commented on KAFKA-7041:
--
I'd agree with your assessment, actually I'm thinking that,
jiameixie commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-629007067
@OneCricketeer Yes, you're right. I recommitted the pr and upgraded openjdk
8 to openjdk 11.
This is an
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107900#comment-17107900
]
Vince Mu commented on KAFKA-6520:
-
Can i be assigned this ticket? I would love to give it a shot.
>
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r425544374
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java
##
@@ -0,0 +1,252 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107885#comment-17107885
]
Sophie Blee-Goldman commented on KAFKA-7041:
> we should also be careful here: just calling
[
https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107884#comment-17107884
]
Sophie Blee-Goldman commented on KAFKA-7912:
I think I actually did end up fixing this in a
[
https://issues.apache.org/jira/browse/KAFKA-7985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7985.
Resolution: Abandoned
Given that this ticket is old and the code was refactored multiple
[
https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7912:
---
Fix Version/s: (was: 2.3.0)
> In-memory key-value store does not support concurrent
[
https://issues.apache.org/jira/browse/KAFKA-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107880#comment-17107880
]
Sophie Blee-Goldman commented on KAFKA-7174:
Technically w.r.t version probing we still just
[
https://issues.apache.org/jira/browse/KAFKA-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7708.
Resolution: Abandoned
> [kafka-streams-scala] Invalid signature for KTable join in 2.12
>
[
https://issues.apache.org/jira/browse/KAFKA-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7445.
Resolution: Not A Problem
> Branch one Stream in multiple Streams
>
wanwenli closed pull request #1779:
URL: https://github.com/apache/kafka/pull/1779
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107876#comment-17107876
]
Matthias J. Sax commented on KAFKA-7271:
[~bbejeck] This is marked as blocker for 2.6 – are you
dengziming commented on pull request #7862:
URL: https://github.com/apache/kafka/pull/7862#issuecomment-628997216
@hachikuji hi Jason, PTAL, thank you.
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7203.
Resolution: Fixed
> Improve Streams StickyTaskAssingor
>
[
https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7209.
Resolution: Abandoned
> Kafka stream does not rebalance when one node gets down
>
[
https://issues.apache.org/jira/browse/KAFKA-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107869#comment-17107869
]
Matthias J. Sax commented on KAFKA-7174:
[~guozhang] [~vvcephei] [~ableegoldman] Given the latest
[
https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7133.
Resolution: Abandoned
> DisconnectException every 5 minutes in single restore consumer
[
https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107868#comment-17107868
]
Matthias J. Sax commented on KAFKA-7041:
Given that bulk-loading results in an increase number of
[
https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7035.
Resolution: Abandoned
> Kafka Processor's init() method sometimes is not called
>
[
https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7015.
Resolution: Not A Problem
We should actually not log sensitive information like key and
[
https://issues.apache.org/jira/browse/KAFKA-7004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7004.
Resolution: Fixed
> Support configurable restore consumer poll timeout
>
[
https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6977.
Resolution: Abandoned
> Kafka Streams - java.lang.IllegalStateException: Unexpected error
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107865#comment-17107865
]
Matthias J. Sax commented on KAFKA-4748:
If we have a mechanism to stop all threads/instances if
[
https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6822.
Resolution: Abandoned
> Kafka Consumer 0.10.2.1 can not normally read data from Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6888.
Resolution: Abandoned
> java.lang.UnsatisfiedLinkError:
[
https://issues.apache.org/jira/browse/KAFKA-6821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6821.
Resolution: Cannot Reproduce
A lot of work on EOS was done recently. Closing this ticket
[
https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107862#comment-17107862
]
Sophie Blee-Goldman commented on KAFKA-5578:
Yup, this pretty much sums up what we've
[
https://issues.apache.org/jira/browse/KAFKA-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6804.
Resolution: Fixed
I believe this is fixed via KAFKA-8501.
> Event values should not be
[
https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6461.
Resolution: Cannot Reproduce
> TableTableJoinIntegrationTest is unstable if caching is
[
https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6237.
Resolution: Cannot Reproduce
There was a lot of EOS work recently. Closing this ticket.
[
https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6182.
Resolution: Fixed
KIP-221 is implemented now. Closing this ticket.
> Automatic
[
https://issues.apache.org/jira/browse/KAFKA-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6125.
Resolution: Not A Problem
> Avoid third party exception to flow through streams code base
[
https://issues.apache.org/jira/browse/KAFKA-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6124.
Resolution: Abandoned
We changed couple of default values (also in consumer/producer/admin
[
https://issues.apache.org/jira/browse/KAFKA-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107852#comment-17107852
]
Matthias J. Sax commented on KAFKA-6039:
[~ableegoldman] [~vvcephei] [~guozhang] I think we can
[
https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6000.
Resolution: Abandoned
> streams 0.10.2.1 - kafka 0.11.0.1 state restore not working
>
[
https://issues.apache.org/jira/browse/KAFKA-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5625.
Resolution: Abandoned
> Invalid subscription data may cause streams app to throw
>
[
https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5581.
Resolution: Fixed
> Avoid creating changelog topics for state stores that are materialized
[
https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107848#comment-17107848
]
Matthias J. Sax commented on KAFKA-5578:
[~ableegoldman] [~cadonna] [~vvcephei] Does KIP-441
[
https://issues.apache.org/jira/browse/KAFKA-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5393.
Resolution: Abandoned
> in-memory state store memory issue
>
[
https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5240.
Resolution: Fixed
> Make persistent checkpointedOffsets optionable
>
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
[
https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107845#comment-17107845
]
Matthias J. Sax commented on KAFKA-4996:
Is this still an issue?
> Fix findbugs multithreaded
[
https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5071.
Resolution: Abandoned
> ERROR StreamThread:783 StreamThread-128 - stream-thread
showuon edited a comment on pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#issuecomment-628563253
Hi @bbejeck , I appended more fixs for the streams documents while I'm
reading it. Please review it when available. Thank you.
[
https://issues.apache.org/jira/browse/KAFKA-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4934.
Resolution: Abandoned
> Add streams test with RocksDb failures
>
[
https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4887.
Resolution: Fixed
> Enabling caching on a persistent window store breaks support for
showuon removed a comment on pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#issuecomment-628403219
Hi @kkonstantine , could you please review this small PR? Thanks.
This is an automated message from the
showuon commented on pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#issuecomment-628981965
hi @ijuma @kkonstantine @mjsax , I've put more fix in the documentation
while I'm reading it. Please help review it when available. Thank you.
[
https://issues.apache.org/jira/browse/KAFKA-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4778.
Resolution: Abandoned
Does not seem to be an issue in newer released any more?
> OOM on
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425518608
##
File path: docs/connect.html
##
@@ -129,9 +129,11 @@ TransformationsThe file source connector reads each line as a String. We will wrap
each line in a
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425522378
##
File path: docs/security.html
##
@@ -1193,7 +1193,7 @@ 7.3
Authentication using SASL7.4 Authorization and
ACLs
Kafka ships with a pluggable
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r420534565
##
File path: docs/security.html
##
@@ -398,7 +398,7 @@ Host Name Verification
ssl.keystore.password=test1234
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r420533008
##
File path: docs/ops.html
##
@@ -477,16 +477,20 @@ Limiting
Bandwidth Usage during Da
Throttle was removed.
The administrator can also validate
[
https://issues.apache.org/jira/browse/KAFKA-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4742.
Resolution: Abandoned
This ticket only affect 0.10.0.x and 0.10.1.x and it's very unlikely
[
https://issues.apache.org/jira/browse/KAFKA-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4697.
Resolution: Abandoned
This tickets only affect 0.10.0.x and 0.10.1.x versions and it's
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425523260
##
File path: docs/security.html
##
@@ -2158,23 +2158,23 @@ 7.6.2 Migrating cluste
Perform a rolling restart of brokers setting the JAAS login
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425523260
##
File path: docs/security.html
##
@@ -2158,23 +2158,23 @@ 7.6.2 Migrating cluste
Perform a rolling restart of brokers setting the JAAS login
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425522820
##
File path: docs/security.html
##
@@ -1438,7 +1438,7 @@ Examples
bin/kafka-acls.sh
--authorizer-properties zookeeper.connect=localhost:2181
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4327:
---
Fix Version/s: 3.0.0
> Move Reset Tool from core to streams
>
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425522820
##
File path: docs/security.html
##
@@ -1438,7 +1438,7 @@ Examples
bin/kafka-acls.sh
--authorizer-properties zookeeper.connect=localhost:2181
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4327:
---
Priority: Blocker (was: Minor)
> Move Reset Tool from core to streams
>
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425522820
##
File path: docs/security.html
##
@@ -1438,7 +1438,7 @@ Examples
bin/kafka-acls.sh
--authorizer-properties zookeeper.connect=localhost:2181
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7566.
Resolution: Won't Fix
> Add sidecar job to leader (or a random single follower) only
>
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425522378
##
File path: docs/security.html
##
@@ -1193,7 +1193,7 @@ 7.3
Authentication using SASL7.4 Authorization and
ACLs
Kafka ships with a pluggable
[
https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-3779.
Resolution: Won't Fix
`KTable#to()` was removed from the API.
> Add the LRU cache for
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
[
https://issues.apache.org/jira/browse/KAFKA-10?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10.
--
Resolution: Won't Fix (was: Abandoned)
Apache Whirr has been retired.
> Kafka deployment on
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425521117
##
File path: docs/security.html
##
@@ -767,7 +767,7 @@ 7.3
Authentication using SASL
> bin/kafka-configs.sh --zookeeper localhost:2182
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425520647
##
File path: docs/connect.html
##
@@ -309,7 +311,7 @@ Connector
}
-We will define the FileStreamSourceTask class below. Next,
we add
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425519960
##
File path: docs/connect.html
##
@@ -174,7 +176,7 @@ TransformationsInsertField - Add a field using either static data or record
metadata
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425519960
##
File path: docs/connect.html
##
@@ -174,7 +176,7 @@ TransformationsInsertField - Add a field using either static data or record
metadata
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425518608
##
File path: docs/connect.html
##
@@ -129,9 +129,11 @@ TransformationsThe file source connector reads each line as a String. We will wrap
each line in a
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425518608
##
File path: docs/connect.html
##
@@ -129,9 +129,11 @@ TransformationsThe file source connector reads each line as a String. We will wrap
each line in a
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425517884
##
File path: docs/connect.html
##
@@ -103,7 +103,7 @@ Configuring Connecto
topics.regex - A Java regular expression of topics to
use as input
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425517884
##
File path: docs/connect.html
##
@@ -103,7 +103,7 @@ Configuring Connecto
topics.regex - A Java regular expression of topics to
use as input
showuon commented on a change in pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#discussion_r425517411
##
File path: docs/connect.html
##
@@ -32,7 +32,7 @@ 8.1
Overview
8.2 User Guide
-The quickstart provides a brief example of how to run a
mjsax commented on a change in pull request #8670:
URL: https://github.com/apache/kafka/pull/8670#discussion_r425514013
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -522,6 +523,12 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107816#comment-17107816
]
victor commented on KAFKA-9981:
---
A new topic/partition is created, but the data is not synchronized.
>
[
https://issues.apache.org/jira/browse/KAFKA-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10001:
--
Description:
Streams' state store ``register()`` function passed in `restoreCallback` can
[
https://issues.apache.org/jira/browse/KAFKA-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-10001:
-
Assignee: Guozhang Wang
> Store's own restore listener should be triggered in store
Guozhang Wang created KAFKA-10001:
-
Summary: Store's own restore listener should be triggered in store
changelog reader
Key: KAFKA-10001
URL: https://issues.apache.org/jira/browse/KAFKA-10001
guozhangwang opened a new pull request #8670:
URL: https://github.com/apache/kafka/pull/8670
The store's registered callback could also be a restore listener, in which
case it should be triggered along with the user specified global listener as
well.
### Committer Checklist
1 - 100 of 188 matches
Mail list logo
