rodesai commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424941145
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
rodesai commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424941145
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
cadonna commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424971223
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
cadonna commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424971223
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
cadonna commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424984599
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
cadonna commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r424984599
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java
##
@@ -53,4 +56,48 @@ void initStoreSerde
[
https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107107#comment-17107107
]
David Jacot commented on KAFKA-7965:
Closing it. Please re-open it if needed.
> Flak
[
https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-7965:
---
Fix Version/s: (was: 2.3.0)
2.6.0
> Flaky Test
> ConsumerBounceTest#testRolli
[
https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-7965.
Resolution: Fixed
> Flaky Test
> ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSi
chia7712 commented on a change in pull request #8665:
URL: https://github.com/apache/kafka/pull/8665#discussion_r425001861
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1015,8 +1015,8 @@ public void subscribe(Collection topics)
showuon commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r425054297
##
File path: docs/streams/developer-guide/dsl-api.html
##
@@ -3738,7 +3738,7 @@ KTable-KTable
Foreign-Key
-T
showuon commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r425055023
##
File path: docs/streams/developer-guide/write-streams.html
##
@@ -208,7 +208,7 @@ Using Kafka Streams within your application code
- Testing a S
showuon commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r425054711
##
File path: docs/streams/developer-guide/write-streams.html
##
@@ -154,7 +154,7 @@ Using Kafka Streams within your application codeStream Partitions and T
showuon commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r425055023
##
File path: docs/streams/developer-guide/write-streams.html
##
@@ -208,7 +208,7 @@ Using Kafka Streams within your application code
- Testing a S
showuon commented on a change in pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#discussion_r425055442
##
File path: docs/streams/developer-guide/running-app.html
##
@@ -51,7 +51,7 @@
Running
Streams Applications
You can run Java applic
showuon commented on pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#issuecomment-628563253
Hi @bbejeck , I appended more fixs for the streams documents. Please review
it when available. Thank you.
This i
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 when I read
it. Please review it when available. Thank you.
-
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. Please review
it when available. Thank you.
d8tltanc edited a comment on pull request #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-628340161
Latest dev branch builds here (REMOVE_SYSTEM_4):
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3944/
--
zhaohaidao commented on a change in pull request #8665:
URL: https://github.com/apache/kafka/pull/8665#discussion_r425097747
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1015,8 +1015,8 @@ public void subscribe(Collection topic
mmolimar commented on a change in pull request #8663:
URL: https://github.com/apache/kafka/pull/8663#discussion_r425115475
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java
##
@@ -108,6 +132,20 @@ public static boolean hasTop
Andras Katona created KAFKA-9992:
Summary: EmbeddedKafka not working with kafka_2.13
Key: KAFKA-9992
URL: https://issues.apache.org/jira/browse/KAFKA-9992
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andras Katona updated KAFKA-9992:
-
Summary: EmbeddedKafkaCluster not working with kafka_2.13 (was:
EmbeddedKafka not working with k
mmolimar commented on a change in pull request #8663:
URL: https://github.com/apache/kafka/pull/8663#discussion_r425135341
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java
##
@@ -96,6 +101,25 @@ public static void validate(M
vvcephei commented on pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#issuecomment-628635918
The test failure was unrelated:
kafka.api.PlaintextConsumerTest.testLowMaxFetchSizeForRequestAndPartition
This i
vvcephei merged pull request #8588:
URL: https://github.com/apache/kafka/pull/8588
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 t
bbejeck commented on pull request #6229:
URL: https://github.com/apache/kafka/pull/6229#issuecomment-628670456
@sh-abhi apologies for letting this slip. Can you rebase this PR? Then we
can get this merged.
Thanks.
T
VinceMu opened a new pull request #8666:
URL: https://github.com/apache/kafka/pull/8666
Used the [previous PR ](https://github.com/apache/kafka/pull/8096) made by
vetler as a starting point.
Updated the printState() method in ConsumerGroup command to only print the
header once whe
rhauch commented on pull request #8654:
URL: https://github.com/apache/kafka/pull/8654#issuecomment-628682601
BTW, I've improved the error message when Connect's `TopicAdmin` fails to
create a topic because of an unknown topic setting:
> Uncaught exception in herder work thread, exit
[
https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107374#comment-17107374
]
Vince Mu commented on KAFKA-9479:
-
PR created [https://github.com/apache/kafka/pull/8666]
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107394#comment-17107394
]
John Roesler commented on KAFKA-9992:
-
Hello Andras,
Just to make sure I understand,
mimaison commented on pull request #8222:
URL: https://github.com/apache/kafka/pull/8222#issuecomment-628718604
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
jeffhuang26 commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-628732206
What is timeline for merging this PR?
This is an automated message from the Apache Git Service.
To respond to
mimaison commented on pull request #8222:
URL: https://github.com/apache/kafka/pull/8222#issuecomment-628745671
Tests passed locally and the generated docs looked good, merging to trunk
This is an automated message from the A
Boyang Chen created KAFKA-9993:
--
Summary: Think about inheritance in the protocol generation
framework
Key: KAFKA-9993
URL: https://issues.apache.org/jira/browse/KAFKA-9993
Project: Kafka
Issue
Boyang Chen created KAFKA-9994:
--
Summary: Catch TaskMigrated exception in task corruption code path
Key: KAFKA-9994
URL: https://issues.apache.org/jira/browse/KAFKA-9994
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9994:
---
Description:
We have seen a case where the TaskMigrated exception gets thrown from
taskManager.commi
James Hay created KAFKA-9995:
Summary: IllegalStateException when offsets not found
Key: KAFKA-9995
URL: https://issues.apache.org/jira/browse/KAFKA-9995
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107487#comment-17107487
]
John Roesler commented on KAFKA-9993:
-
Thanks for the idea, Boyang. Can you clarify w
mjsax commented on pull request #8665:
URL: https://github.com/apache/kafka/pull/8665#issuecomment-628779775
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r425314470
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -169,6 +173,9 @@ public void makeRead
ableegoldman commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r425314263
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -169,6 +173,9 @@ public void makeRead
abbccdda opened a new pull request #8667:
URL: https://github.com/apache/kafka/pull/8667
The TaskMigratedException should always be non-fatal and caught within the
run loop. Adding try-catch for corrupted path as well is necessary.
### Committer Checklist (excluded from commit messag
mjsax commented on pull request #8667:
URL: https://github.com/apache/kafka/pull/8667#issuecomment-628795711
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r425330736
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -169,6 +173,9 @@ public void makeReady(fi
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107523#comment-17107523
]
Matthias J. Sax commented on KAFKA-9676:
[~bchen225242] There is still no `Standb
guozhangwang commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r425343094
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -1520,38 +1534,6 @@ private stati
mjsax commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628810936
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-62881
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8558:
URL: https://github.com/apache/kafka/pull/8558#issuecomment-628812878
Yes, on the voting thread: I proposed to also deprecate `through()` via
KIP-221 and Guozhang replied. But it's your KIP and I don't want to "hijack" it
:) -- I am willing to do the
Emanuele Maccherani created KAFKA-9996:
--
Summary: upgrade zookeeper to 3.5.8 to address security
vulnerabilities
Key: KAFKA-9996
URL: https://issues.apache.org/jira/browse/KAFKA-9996
Project: Kaf
vvcephei commented on a change in pull request #8667:
URL: https://github.com/apache/kafka/pull/8667#discussion_r425348145
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -555,28 +555,35 @@ void runLoop() {
Emanuele Maccherani created KAFKA-9997:
--
Summary: upgrade log4j lib to address CVE-2020-9488
Key: KAFKA-9997
URL: https://issues.apache.org/jira/browse/KAFKA-9997
Project: Kafka
Issue Ty
ableegoldman opened a new pull request #8668:
URL: https://github.com/apache/kafka/pull/8668
Motivation and pseudo code algorithm in the ticket.
[WIP] still need to finish writing tests and gather rough benchmark results
--
mimaison merged pull request #8222:
URL: https://github.com/apache/kafka/pull/8222
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 t
abbccdda commented on a change in pull request #8667:
URL: https://github.com/apache/kafka/pull/8667#discussion_r425366150
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -555,28 +555,35 @@ void runLoop() {
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107584#comment-17107584
]
Hai Lin commented on KAFKA-9987:
Thanks for putting this up. From the above algorithm, lo
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107585#comment-17107585
]
Hai Lin commented on KAFKA-9987:
Saw the PR, I will take a look.
> Improve sticky partit
vvcephei commented on a change in pull request #8667:
URL: https://github.com/apache/kafka/pull/8667#discussion_r425386296
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -555,28 +555,35 @@ void runLoop() {
radai rosenblatt created KAFKA-9998:
---
Summary: KafkaProducer.close(timeout) still may block indefinitely
Key: KAFKA-9998
URL: https://issues.apache.org/jira/browse/KAFKA-9998
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not guarante
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107623#comment-17107623
]
Boyang Chen commented on KAFKA-9989:
Discussed with [~cadonna] and it seems to be cau
Boyang Chen created KAFKA-:
--
Summary: Topic description should be triggered after each failed
topic creation iteration
Key: KAFKA-
URL: https://issues.apache.org/jira/browse/KAFKA-
Project:
ableegoldman commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628879075
Java 14 build passed, Java 8 din't build due to
```
11:29:13 # There is insufficient memory for the Java Runtime Environment to
continue.
11:29:13 # Cannot create GC
vvcephei merged pull request #8662:
URL: https://github.com/apache/kafka/pull/8662
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 t
vvcephei commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628881057
Thanks, @ableegoldman !
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107672#comment-17107672
]
Boyang Chen commented on KAFKA-9676:
The current trunk has logic coverage for Standby
rhauch commented on pull request #8654:
URL: https://github.com/apache/kafka/pull/8654#issuecomment-628885132
I've added some integration tests for creating the internal topic, including
verifying some existing functionality w/r/t the replication factor and number
of partitions with variou
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9984.
Fix Version/s: 2.6.0
Resolution: Fixed
> Should fail the subscription when pattern i
mjsax merged pull request #8665:
URL: https://github.com/apache/kafka/pull/8665
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 the
mjsax commented on pull request #8665:
URL: https://github.com/apache/kafka/pull/8665#issuecomment-628892193
Thanks for the fix @zhaohaidao! Merged to `trunk`.
This is an automated message from the Apache Git Service.
To resp
rhauch commented on pull request #8090:
URL: https://github.com/apache/kafka/pull/8090#issuecomment-628895259
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
d8tltanc removed a comment on pull request #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-62030
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3931/
Link for the system tests ⬆️
T
rhauch commented on pull request #8618:
URL: https://github.com/apache/kafka/pull/8618#issuecomment-628898153
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
mumrah commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r425443889
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,102 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
OneCricketeer commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-628906219
Since Java 8 is EOL, why not upgrade to openjdk 11?
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107726#comment-17107726
]
Boyang Chen commented on KAFKA-9993:
Thanks [~vvcephei] An example is from the recent
ableegoldman opened a new pull request #8669:
URL: https://github.com/apache/kafka/pull/8669
This is a prerequisite for
[KAFKA-9501](https://github.com/apache/kafka/pull/8248/) and will also be
useful for [KAFKA-9603](https://github.com/apache/kafka/pull/8661)
There should be no log
ableegoldman commented on pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#issuecomment-628915649
Call for review @cadonna @guozhangwang @vvcephei
This is an automated message from the Apache Git Service.
T
ableegoldman commented on a change in pull request #8669:
URL: https://github.com/apache/kafka/pull/8669#discussion_r425467074
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -198,433 +196,51 @@ public StateStore
Chris Egerton created KAFKA-1:
-
Summary: Atomic commit of source connector records and offsets
Key: KAFKA-1
URL: https://issues.apache.org/jira/browse/KAFKA-1
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-1:
--
Description:
It'd be nice to be able to configure source connectors such that their offsets
a
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-1:
--
Labels: needs-kip (was: )
> Atomic commit of source connector records and offsets
> -
vvcephei merged pull request #8667:
URL: https://github.com/apache/kafka/pull/8667
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 t
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 (exclude
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
Project:
[
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
pot
[
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 cha
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107816#comment-17107816
]
victor commented on KAFKA-9981:
---
A new topic/partition is created, but the data is not syn
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 restoreChange
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 stan
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 for
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 for
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 M
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 M
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
Replac
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
Replac
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 some
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 --zk-tls-confi
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 --zk-tls-confi
1 - 100 of 185 matches
Mail list logo